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

When using in embedded mode MYSQL connector fails

    XMLWordPrintable

Details

    Description

      I get the following error during the initial sync:-

      2020-01-07 12:11:31 ERROR SnapshotReader:208 - Failed due to error: Aborting snapshot due to error when last running 'SHOW CREATE TABLE `performance_schema`.`accounts`': Invalid value: null used for required field: "db", schema type: STRING
      org.apache.kafka.connect.errors.ConnectException: Invalid value: null used for required field: "db", schema type: STRING
      	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:839)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
      	at java.lang.Thread.run(Unknown Source)
      Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "db", schema type: STRING
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
      	at io.debezium.connector.AbstractSourceInfoStructMaker.commonStruct(AbstractSourceInfoStructMaker.java:54)
      	at io.debezium.connector.mysql.MySqlSourceInfoStructMaker.struct(MySqlSourceInfoStructMaker.java:40)
      	at io.debezium.connector.mysql.MySqlSourceInfoStructMaker.struct(MySqlSourceInfoStructMaker.java:14)
      	at io.debezium.connector.AbstractSourceInfo.struct(AbstractSourceInfo.java:76)
      	at io.debezium.connector.mysql.RecordMakers.schemaChangeRecordValue(RecordMakers.java:379)
      	at io.debezium.connector.mysql.RecordMakers.schemaChanges(RecordMakers.java:145)
      	at io.debezium.connector.mysql.SnapshotReader.enqueueSchemaChanges(SnapshotReader.java:1031)
      	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:346)
      	at io.debezium.connector.mysql.SnapshotReader.lambda$readTableSchema$15(SnapshotReader.java:857)
      	at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:453)
      	at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:394)
      	at io.debezium.connector.mysql.SnapshotReader.readTableSchema(SnapshotReader.java:855)
      	at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:779)
      	... 3 more
      

      Source system is MySQL 5.7 on AWS RDS

      Have attached the test code used to run Debezium.

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            ed.thompson Ed Thompson (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: