-
Bug
-
Resolution: Done
-
Major
-
2.7.4.Final, 3.0.1.Final
-
None
-
False
-
None
-
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