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

Debezium Oracle connector 1.6.0.Beta1 LogMiner ParsingException during streaming start

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Minor
    • None
    • 1.6.0.Beta1
    • oracle-connector
    • None
    • False
    • False
    • Undefined

    Description

      Using the oracle-vagrant-box as a test DB and a Confluent Platform connect base, we have been able to get the first snapshot and rows produced in Kafka. However when the connector starts the streaming process the following error is encountered.

      [2021-06-08 00:06:17,475] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper)
      io.debezium.text.ParsingException: Failed to parse operator at index 347: DECLARE 
       loc_c CLOB; 
       buf_c VARCHAR2(6186); 
       loc_b BLOB; 
       buf_b RAW(6186); 
       loc_nc NCLOB; 
       buf_nc NVARCHAR2(6186); 
      BEGIN
       select "REPORT_COMPRESSED" into loc_b from "SYS"."WRP$_REPORTS_DETAILS" where "SNAP_ID" = '2' and "DBID" = '2845641654' and "INSTANCE_NUMBER" = '1' and "REPORT_ID" = '34' and "CON_DBID" = '2845641654' and "SESSION_ID" IS NULL and "SESSION_SERIAL#" IS NULL and "GENERATION_TIME" = TO_DATE('2021-06-07 08:35:44', 'YYYY-MM-DD HH24:MI:SS') for update;       at io.debezium.connector.oracle.logminer.parser.SelectLobParser.parseOperator(SelectLobParser.java:234)
             at io.debezium.connector.oracle.logminer.parser.SelectLobParser.parseWhere(SelectLobParser.java:189)
             at io.debezium.connector.oracle.logminer.parser.SelectLobParser.parse(SelectLobParser.java:76)
             at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:191)
             at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:188)
             at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
             at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
             at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
             at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
             at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
             at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
             at java.base/java.lang.Thread.run(Thread.java:834)
      
      

      Attachments

        Issue Links

          Activity

            People

              ccranfor@redhat.com Chris Cranford
              ablackmore-1 Angus Blackmore (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: