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

IncrementalSnapshotCaseSensitiveIT#insertDeleteWatermarkingStrategy fails

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 2.5.0.Final
    • 2.5.0.CR1
    • oracle-connector
    • None

      IncrementalSnapshotCaseSensitiveIT#insertDeleteWatermarkingStrategy fails on Oracle with

      2023-12-19 00:44:16,036 WARN   Oracle|server1|streaming  Action execute-snapshot failed. The signal SignalRecord{id='ad-hoc', type='execute-snapshot', data='{"type": "INCREMENTAL","data-collections": ["ORCLPDB1.DEBEZIUM.A"]}', additionalData={}} may not have been processed.   [io.debezium.pipeline.signal.SignalProcessor]
      io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'DataCollection{id=ORCLPDB1.DEBEZIUM.A, additionalCondition=, surrogateKey=}'
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:411)
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.addDataCollectionNamesToSnapshot(AbstractIncrementalSnapshotChangeEventSource.java:521)
              at io.debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot.arrived(ExecuteSnapshot.java:78)
              at io.debezium.pipeline.signal.SignalProcessor.processSignal(SignalProcessor.java:191)
              at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
              at java.base/java.util.AbstractList$RandomAccessSpliterator.forEachRemaining(AbstractList.java:722)
              at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)
              at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
              at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
              at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
              at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
              at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
              at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
              at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
              at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
              at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
              at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
              at io.debezium.pipeline.signal.SignalProcessor.lambda$processSourceSignal$4(SignalProcessor.java:155)
              at io.debezium.pipeline.signal.SignalProcessor.executeWithSemaphore(SignalProcessor.java:165)
              at io.debezium.pipeline.signal.SignalProcessor.processSourceSignal(SignalProcessor.java:149)
              at io.debezium.pipeline.EventDispatcher$2.changeRecord(EventDispatcher.java:290)
              at io.debezium.relational.RelationalChangeRecordEmitter.emitCreateRecord(RelationalChangeRecordEmitter.java:79)
              at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:47)
              at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:271)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor$1.accept(AbstractLogMinerEventProcessor.java:523)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor$1.accept(AbstractLogMinerEventProcessor.java:475)
              at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.dispatchChangeEvent(TransactionCommitConsumer.java:380)
              at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.accept(TransactionCommitConsumer.java:117)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleCommit(AbstractLogMinerEventProcessor.java:547)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:353)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:305)
              at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:233)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:248)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:62)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137)
              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:1583)
      Caused by: java.sql.SQLSyntaxErrorException: ORA-01031: insufficient privileges
      
              at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:630)
              at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:564)
              at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1151)
              at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:771)
              at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
              at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:498)
              at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:152)
              at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1052)
              at oracle.jdbc.driver.OracleStatement.executeSQLStatement(OracleStatement.java:1531)
              at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1311)
              at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3746)
              at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3941)
              at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1010)
              at io.debezium.jdbc.JdbcConnection.prepareUpdate(JdbcConnection.java:758)
              at io.debezium.pipeline.source.snapshot.incremental.DeleteWindowCloser.closeWindow(DeleteWindowCloser.java:37)
              at io.debezium.pipeline.source.snapshot.incremental.SignalBasedIncrementalSnapshotChangeEventSource.emitWindowClose(SignalBasedIncrementalSnapshotChangeEventSource.java:83)
              at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:408)
              ... 41 common frames omitted
      Caused by: oracle.jdbc.OracleDatabaseException: ORA-01031: insufficient privileges
      
              at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:637)
              ... 57 common frames omitted
      

      Moreover, it takes more 30 minutes for the test to fail.

              vjuranek@redhat.com Vojtech Juranek
              vjuranek@redhat.com Vojtech Juranek
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: