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

Use optional schema for Timezone Converter tests

XMLWordPrintable

    • False
    • None
    • False

      org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:230)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:156)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.convertTransformedRecord(AbstractWorkerSourceTask.java:488)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:396)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:361)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:75)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181)
      debezium-timezone-smt-connect-1    | 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
      debezium-timezone-smt-connect-1    | 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      debezium-timezone-smt-connect-1    | 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      debezium-timezone-smt-connect-1    | 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      debezium-timezone-smt-connect-1    | 	at java.base/java.lang.Thread.run(Thread.java:829)
      debezium-timezone-smt-connect-1    | Caused by: org.apache.kafka.connect.errors.DataException: Conversion error: null value for field that is required and has no default value
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.json.JsonConverter.convertToJson(JsonConverter.java:571)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.json.JsonConverter.convertToJson(JsonConverter.java:664)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.json.JsonConverter.convertToJsonWithEnvelope(JsonConverter.java:552)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.json.JsonConverter.fromConnectData(JsonConverter.java:306)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:64)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.lambda$convertTransformedRecord$6(AbstractWorkerSourceTask.java:488)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:180)
      debezium-timezone-smt-connect-1    | 	at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:214)
      debezium-timezone-smt-connect-1    | 	... 13 more
      

            anmohant Anisha Mohanty
            anmohant Anisha Mohanty
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: