Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4372

capture mysql table fail

    XMLWordPrintable

Details

    • Bug
    • Resolution: Cannot Reproduce
    • Major
    • None
    • 1.7.1.Final
    • mysql-connector
    • None
    • False
    • False

    Description

      234

      I use debezium to capture mysql single table, can`t success and error info "Producer failure" caused by "Lock wait timeout"

      Components (docker):

      • debezium/connect:1.7
      • mysql: 5.7.23-log MySQL Community Server (GPL)
      • grants

         

      error logs:

       2021-11-29 09:27:41,936 INFO   MySQL|mysql|snapshot  Writes to MySQL tables prevented for a total of 00:00:28.465   [io.debezium.connector.mysql.MySqlSnapshotChangeEventSource]
      2021-11-29 09:27:53,799 INFO   MySQL|mysql|snapshot  Snapshot - Final stage   [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource]
      2021-11-29 09:27:53,801 ERROR  MySQL|mysql|snapshot  Producer failure   [io.debezium.pipeline.ErrorHandler]
      io.debezium.DebeziumException: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Lock wait timeout exceeded; try restarting transaction
          at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:79)
          at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:118)
          at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
          at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
          at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
          at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
          at java.base/java.lang.Thread.run(Thread.java:829)
      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.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
          at com.mysql.cj.jdbc.StatementImpl.executeQuery(StatementImpl.java:1202)
          at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:556)
          at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:499)
          at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.createSchemaEventsForTables(MySqlSnapshotChangeEventSource.java:371)
          at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.releaseDataSnapshotLocks(MySqlSnapshotChangeEventSource.java:232)
          at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEvents(RelationalSnapshotChangeEventSource.java:318)
          at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:135)
          at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:70)
          ... 6 more
      2021-11-29 09:27:54,283 INFO   ||  WorkerSourceTask{id=console-connector-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
      2021-11-29 09:27:54,294 ERROR  ||  WorkerSourceTask{id=console-connector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted  

      Attachments

        Activity

          People

            Unassigned Unassigned
            qstesiro mengmeng huang (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: