-
Bug
-
Resolution: Done
-
Critical
-
1.0.0.Final
-
None
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.