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

MySQL connector should tolerate 'null' values for the binlog filename in certain cases

    XMLWordPrintable

Details

    • Enhancement
    • Resolution: Done
    • Major
    • 0.3
    • 0.3
    • mysql-connector
    • None

    Description

      Below error is raised when doing snapshot.

      2016-08-05 15:48:56,750 INFO   MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Step 6: generating DROP and CREATE statements to reflect current database schemas   [io.debezium.connector.mysql.SnapshotReader]
      2016-08-05 15:48:58,149 INFO   MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Step 6b: applying DROP and CREATE statements to connector's table model   [io.debezium.connector.mysql.SnapshotReader]
      2016-08-05 15:48:58,244 ERROR  MySQL|mysql_host_52_70_200_92_port_3306|snapshot  Failed due to error: Aborting snapshot after running 'SHOW CREATE TABLE gpay.transaction_psms': Invalid value: null used for required field   [io.debezium.connector.mysql.SnapshotReader]
      org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field
          at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:210)
          at org.apache.kafka.connect.data.Struct.put(Struct.java:215)
          at org.apache.kafka.connect.data.Struct.put(Struct.java:204)
          at io.debezium.connector.mysql.SourceInfo.struct(SourceInfo.java:230)
          at io.debezium.connector.mysql.RecordMakers.schemaChangeRecordValue(RecordMakers.java:318)
          at io.debezium.connector.mysql.RecordMakers.schemaChanges(RecordMakers.java:123)
          at io.debezium.connector.mysql.SnapshotReader.enqueueSchemaChanges(SnapshotReader.java:536)
          at io.debezium.connector.mysql.MySqlSchema.lambda$applyDdl$3(MySqlSchema.java:339)
          at io.debezium.relational.ddl.DdlChanges.lambda$groupStatementStringsByDatabase$1(DdlChanges.java:72)
          at io.debezium.relational.ddl.DdlChanges.groupEventsByDatabase(DdlChanges.java:97)
          at io.debezium.relational.ddl.DdlChanges.groupStatementStringsByDatabase(DdlChanges.java:66)
          at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:336)
          at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:295)
          at java.lang.Thread.run(Thread.java:745)
      2016-08-05 15:48:58,648 ERROR  ||  Task gpay-0 threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
      

      Attachments

        Activity

          People

            hchiorean Horia Chiorean (Inactive)
            mvj3_jira David Chen (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: