当我使用flink cdc 对多张表进行关联查询时其中的一张表总是会有锁超时的情况,导致任务无法正常启动,
请问这种情况应该如何处理? org.apache.kafka.connect.errors.ConnectException: Lock wait timeout exceeded; try restarting transaction Error code: 1205; SQLSTATE: 40001. at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:831) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:123) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:782) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:666) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1201) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:465) ... 3 more |
有更完整的堆栈不? 在 2020-11-11 10:28:02,"丁浩浩" <[hidden email]> 写道: >当我使用flink cdc 对多张表进行关联查询时其中的一张表总是会有锁超时的情况,导致任务无法正常启动, >请问这种情况应该如何处理? >org.apache.kafka.connect.errors.ConnectException: Lock wait timeout exceeded; try restarting transaction Error code: 1205; SQLSTATE: 40001. > at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) > at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207) > at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:831) > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) >Caused by: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction > at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:123) > at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) > at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) > at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:782) > at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:666) > at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1201) > at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:465) > ... 3 more |
Free forum by Nabble | Edit this page |