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

DataException: Only Struct objects supported for [Updating schema]

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Won't Do
    • Icon: Major Major
    • None
    • 0.6.1
    • connect-service
    • 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 ...... :

      {db1.abc.def=LEADER_NOT_AVAILABLE}

      [org.apache.kafka.clients.NetworkClient]
      2017-10-26 22:48:04,546 INFO || Finished WorkerSourceTask

      {id=inventory-connector-0}

      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]

              Unassigned Unassigned
              jaggaer-afoxson Adam Foxson (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: