-
Bug
-
Resolution: Done
-
Major
-
2.7.4.Final, 3.0.1.Final
-
None
-
False
-
-
False
-
-
After applying changes in DBZ-8277, the ReselectPostProcessor fails when streaming changes using XStream:
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67)
at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:130)
at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
at oracle.streams.XStreamOut.receiveLCRCallback(Unknown Source)
at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:116)
at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:46)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:324)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1575)
Caused by: org.apache.kafka.connect.errors.ConnectException: Error while processing event at offset {lcr_position=0000000000231af400000001000000010000000000231af3000000010000000102, snapshot_scn=2299467}
at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:327)
at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchDataChangeEvent(LcrEventHandler.java:240)
at io.debezium.connector.oracle.xstream.LcrEventHandler.processRowLCR(LcrEventHandler.java:149)
at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:117)
... 12 common frames omitted
Caused by: java.lang.RuntimeException: java.sql.SQLTimeoutException: ORA-01013: user requested cancel of current operation
at io.debezium.connector.oracle.OracleConnection.resetSessionToCdb(OracleConnection.java:149)
at io.debezium.connector.oracle.OracleConnection.optionallyDoInContainer(OracleConnection.java:723)
at io.debezium.connector.oracle.OracleConnection.reselectColumns(OracleConnection.java:657)
at io.debezium.processors.reselect.ReselectColumnsPostProcessor.apply(ReselectColumnsPostProcessor.java:168)
at io.debezium.pipeline.EventDispatcher.doPostProcessing(EventDispatcher.java:745)
at io.debezium.pipeline.EventDispatcher$StreamingChangeRecordReceiver.changeRecord(EventDispatcher.java:506)
at io.debezium.pipeline.EventDispatcher$2.changeRecord(EventDispatcher.java:304)
at io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:124)
at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:53)
at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:275)
... 15 common frames omitted
Caused by: java.sql.SQLTimeoutException: ORA-01013: user requested cancel of current operation
at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1301)
at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1183)
at oracle.jdbc.driver.T2CStatement.executeForDescribe(T2CStatement.java:968)
at oracle.jdbc.driver.T2CStatement.executeForRows(T2CStatement.java:1219)
at oracle.jdbc.driver.OracleStatement.executeSQLStatement(OracleStatement.java:1820)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1472)
at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:2505)
at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:2460)
at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:328)
at io.debezium.connector.oracle.OracleConnection.resetSessionToCdb(OracleConnection.java:146)
... 24 common frames omitted
Caused by: oracle.jdbc.OracleDatabaseException: ORA-01013: user requested cancel of current operation
at oracle.jdbc.driver.T2CConnection.checkError(T2CConnection.java:1315)
... 33 common frames omitted
- is caused by
-
DBZ-8277 Reselect Post Processor not working when pkey of type uuid etc.
-
- Closed
-