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

Debezium raised an exception and the task was still running

XMLWordPrintable

      Debezium raised an exception , the status of the Debezium task was still running, But Debezium doesn't produce message any more.

      I met this error once , and I don't know how to reproduce it.

      Eviorment: Debezium 1.8.1.Final , oracle11g & xstream

       

      [2022-04-11 09:52:04,580] INFO WorkerSourceTask{id=sysp-oracle-extract-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
      [2022-04-11 09:52:14,581] INFO WorkerSourceTask{id=sysp-oracle-extract-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
      Exception in thread "debezium-oracleconnector-sysp-change-event-source-coordinator" io.debezium.DebeziumException: Couldn't set processed low watermark
          at io.debezium.connector.oracle.xstream.LcrEventHandler.setWatermark(LcrEventHandler.java:325)
          at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:88)
          at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
          at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
          at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108)
          at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43)
          at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172)
          at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
          at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
          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)
      Caused by: oracle.streams.StreamsException: ORA-26876: invalid processed low-watermark (current position=ffffa276b0e30000000000000000ffffa276b0e3000000000000000001; new position=0003a287896100000001000000010003a2876402000000120000000101) 
          at oracle.streams.XStreamOut.XStreamOutSetProcessedLowWatermarkNative(Native Method)
          at oracle.streams.XStreamOut.setProcessedLowWatermark(XStreamOut.java:696)
          at io.debezium.connector.oracle.xstream.LcrEventHandler.setWatermark(LcrEventHandler.java:306)
          ... 13 more
      [2022-04-11 09:52:24,581] INFO WorkerSourceTask{id=sysp-oracle-extract-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
      [2022-04-11 09:52:34,582] INFO WorkerSourceTask{id=sysp-oracle-extract-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)

            ccranfor@redhat.com Chris Cranford
            jian.zhu.86 jian zhu (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

              Created:
              Updated:
              Resolved: