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

Mysql Snapshot reader not quit after encounter an error

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Major
    • None
    • 0.9.5.Final
    • mysql-connector
    • None
    • Hide

      1. change the database config from master to slave
      2. restart the connector with table white list
      3. failed to read binlog with error but task still running

      Show
      1. change the database config from master to slave 2. restart the connector with table white list 3. failed to read binlog with error but task still running

    Description

      [2019-09-06 04:53:15,593] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
      [2019-09-06 04:53:15,593] ERROR WorkerSourceTask{id=debezium-connector-mysql-tb-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
      org.apache.kafka.connect.errors.ConnectException: Can not read response from server. Expected to read 15,054,484 bytes, read 3,624,253 bytes before connection was unexpectedly lost. Error code: 0; SQLSTATE: S1000.
              at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
              at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
              at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:721)
              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: java.sql.SQLException: Can not read response from server. Expected to read 15,054,484 bytes, read 3,624,253 bytes before connection was unexpectedly lost.
              at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
              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.ConnectionImpl.commit(ConnectionImpl.java:813)
              at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:636)
              ... 3 more
      [2019-09-06 04:53:15,593] ERROR WorkerSourceTask{id=debezium-connector-mysql-tb-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180)
      [2019-09-06 04:53:15,593] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:430)
      [2019-09-06 04:53:15,593] INFO ChainedReader: Stopping the snapshot reader (io.debezium.connector.mysql.ChainedReader:121)
      [2019-09-06 04:53:15,593] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.SnapshotReader:129)
      [2019-09-06 04:53:15,594] INFO Discarding 0 unsent record(s) due to the connector shutting down (io.debezium.connector.mysql.SnapshotReader:129)
      [2019-09-06 04:53:15,594] INFO [Producer clientId=debezium-connector-mysql-tb-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1153)
      [2019-09-06 04:53:15,597] INFO Connector task finished all work and is now shutdown (io.debezium.connector.mysql.MySqlConnectorTask:465)
      [2019-09-06 04:53:15,597] ERROR Unable to unregister the MBean 'debezium.mysql:type=connector-metrics,context=snapshot,server=data_connector' (io.debezium.connector.mysql.SnapshotReader:81)
      [2019-09-06 04:53:15,597] ERROR Unable to unregister the MBean 'debezium.mysql:type=connector-metrics,context=binlog,server=data_connector' (io.debezium.connector.mysql.BinlogReader:81)
      [2019-09-06 04:53:15,597] INFO [Producer clientId=connector-producer-debezium-connector-mysql-tb-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1153)
      [2019-09-06 04:53:22,669] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:398)
      [2019-09-06 04:53:22,670] INFO WorkerSourceTask{id=debezium-connector-mysql-tb-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:415)
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            daxingyu xingyu da (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: