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

java.lang.NullPointerException in ByLogicalTableRouter.java

XMLWordPrintable

      Upgrading debezium to release 1.2.1.Final I run into following problem. (Configurations are still the same, only image has been upgraded.)

      debezium-local | 2020-08-07 07:53:11,972 ERROR  ||  WorkerSourceTask{id=sage-connector-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
      debezium-local | org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
      debezium-local |        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)
      debezium-local |        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)
      debezium-local |        at org.apache.kafka.connect.runtime.TransformationChain.apply(TransformationChain.java:50)
      debezium-local |        at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:320)
      debezium-local |        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:245)
      debezium-local |        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184)
      debezium-local |        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)
      debezium-local |        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
      debezium-local |        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      debezium-local |        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      debezium-local |        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      debezium-local |        at java.base/java.lang.Thread.run(Thread.java:834)
      debezium-local | Caused by: java.lang.NullPointerException
      debezium-local |        at io.debezium.transforms.ByLogicalTableRouter.updateEnvelopeSchema(ByLogicalTableRouter.java:325)
      debezium-local |        at io.debezium.transforms.ByLogicalTableRouter.apply(ByLogicalTableRouter.java:217)
      debezium-local |        at org.apache.kafka.connect.runtime.TransformationChain.lambda$apply$0(TransformationChain.java:50)
      debezium-local |        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)
      debezium-local |        at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)
      debezium-local |        ... 11 more
      
      

            Unassigned Unassigned
            damiano01 Damiano Pisconti (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: