-
Bug
-
Resolution: Won't Do
-
Major
-
None
-
0.6.1
-
None
I received the following exception on a fresh 0.6.1 (when a specific database was included). I'm happy to provide whatever additional information may be useful.
2017-10-26 22:48:00,974 INFO MySQL|db1|snapshot Step 8: - scanning table 'abc.def' (4888 of 5190 tables) [io.debezium.connector.mysql.SnapshotReader]
2017-10-26 22:48:00,999 WARN || Error while fetching metadata with correlation id ...... :
[org.apache.kafka.clients.NetworkClient]
2017-10-26 22:48:04,546 INFO || Finished WorkerSourceTask
commitOffsets successfully in 33 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
2017-10-26 22:48:04,546 ERROR || Task inventory-connector-0 threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.DataException: Only Struct objects supported for [Updating schema], found: null
at org.apache.kafka.connect.transforms.util.Requirements.requireStruct(Requirements.java:45)
at io.debezium.transforms.ByLogicalTableRouter.apply(ByLogicalTableRouter.java:182)
at org.apache.kafka.connect.runtime.TransformationChain.apply(TransformationChain.java:38)
at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:190)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:168)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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)
2017-10-26 22:48:04,546 ERROR || Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]
2017-10-26 22:48:04,546 INFO || Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer]