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

Debezium Oracle connector 1.6.0.Beta1 LogMiner ParsingException during streaming start

XMLWordPrintable

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

      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)
      
      

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

              Created:
              Updated:
              Resolved: