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

ReselectPostProcessor fails when reselecting columns from Oracle

XMLWordPrintable

      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
      

              ccranfor@redhat.com Chris Cranford
              ccranfor@redhat.com Chris Cranford
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: