Details
-
Task
-
Resolution: Done
-
Major
-
1.8.1.Final
-
None
-
False
-
None
-
False
Description
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)
