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

Oracle Logminer ParserDML - Statement couldn't be parsed for XMLType

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Duplicate
    • Icon: Major Major
    • None
    • 1.5.4.Final, 1.6.0.Final
    • oracle-connector
    • None
    • False
    • False
    • Undefined
    • Hide
      1. Install debezuim source connector
      2. create new records in database
      3. check kafka connect log

       

      Show
      Install debezuim source connector create new records in database check kafka connect log  

      We are using debezuim oracle connector to stream data from oracle database. The data is streamed and loaded into kafka topics at the first initial load after the connector get installed.  The new inserted/Updated records in Oracle datable are failed to load into kafka topics.

       

      Below is sample error message.

      ------------------------------------------------------------------------------------------------

      [2021-07-22 15:51:53,062] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:527)
      io.debezium.connector.oracle.logminer.parser.DmlParserException: DML statement couldn't be parsed. Please open a Jira issue with the statement 'update "CUSTOMER" a set a."XMLRECORD" = XMLType('<row id=''1371523''><c1>POCH860501</c1><c2>Test Data</c2><c2 m=''2''>Test Data</c2><c2 m=''3''>Test Data</c2><c2 m=''4''>Test Data</c2><c2 m=''5''>Test Data</c2><c2 m=''6''>Test Data</c2><c3>Test Data</c3><c3 m=''2''>Test Data</c3><c3 m=''3''>Test Data</c3><c3 m=''4''>Test Data</c3><c3 m=''5''>Test Data</c3><c3 m=''6''>Test Data</c3><c5>,</c5><c6>2109</c6><c7>21091205</c7><c9>210912</c9><c23>1036</c23><c24>4107</c24><c26>1055</c26><c27>999</c27><c28>KH</c28><c29>24</c29><c30>KH</c30><c34>1390604985</c34><c42>19860510</c42><c45>6</c45><c48>KH0010116</c48><c52>NO</c52><c60>MRS</c60><c61>Test Data</c61><c62>Test Data</c62><c63>FEMALE</c63><c65>SINGLE</c65><c94>1390604985-</c94><c133>NULL</c133><c134>NULL</c134><c137>NULL</c137><c138>NULL</c138><c179>4</c179><c179 m=''2''>HS</c179><c179 m=''3''>21</c179><c179 m=''4''>2109</c179><c179 m=''5''>210912</c179><c179 m=''6''>21091205</c179><c179 m=''7''>123456</c179><c179 m=''19''>0976369092</c179><c179 m=''20''>Y</c179><c179 m=''22''>Test Data</c179><c179 m=''24''>Y</c179><c179 m=''25''>Y</c179><c179 m=''26''>N</c179><c179 m=''27''>N</c179><c179 m=''36''>20170105</c179><c179 m=''37''>I</c179><c179 m=''41''>1</c179><c179 m=''43''>3</c179><c179 m=''44''>4</c179><c179 m=''46''>1</c179><c179 m=''70''>Y</c179><c179 m=''71''>34</c179><c179 m=''72''>20221029</c179><c179 m=''77''>20170105</c179><c179 m=''79''>20170105</c179><c179 m=''89''>1</c179><c179 m=''125''>Y</c179><c179 m=''126''>Y</c179><c179 m=''127''>Y</c179><c179 m=''132''>N</c179><c179 m=''134''>N</c179><c179 m=''139''>N</c179><c179 m=''153''>N</c179><c179 m=''155''>03</c179><c179 m=''156''>0313</c179><c179 m=''157''>031303</c179><c179 m=''158''>03130317</c179><c179 m=''159''>N</c179><c179 m=''162''>N</c179><c179 m=''163''>N</c179><c179 m=''171''>0</c179><c179 m=''192''>19860505190604985</c179><c179 m=''200''></c179><c182>2</c182><c183>1188_.USER_I_INAU_OFS_BROWSERTC</c183><c184>2106141532</c184><c184 m=''2''>2106141530</c184><c185>1188_USER</c185><c186>KH0010001</c186><c187>1</c187></row>') where a."RECID" = '1371523';'. You can set internal.log.mining.dml.parser='legacy' as a workaround until the parse error is fixed.
      at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.parse(LogMinerQueryResultProcessor.java:291)
      at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:209)
      at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:187)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:152)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:119)
      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)
      Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: Failed to parse update DML: 'update "CUSTOMER" a set a."XMLRECORD" = XMLType('<row id=''1371523''><c1>POCH860501</c1><c2>Test Data</c2><c2 m=''2''>Test Data</c2><c2 m=''3''>Test Data</c2><c2 m=''4''>Test Data</c2><c2 m=''5''>Test Data</c2><c2 m=''6''>Test Data</c2><c3>Test Data</c3><c3 m=''2''>Test Data</c3><c3 m=''3''>Test Data</c3><c3 m=''4''>Test Data</c3><c3 m=''5''>Test Data</c3><c3 m=''6''>Test Data</c3><c5>,</c5><c6>2109</c6><c7>21091205</c7><c9>210912</c9><c23>1036</c23><c24>4107</c24><c26>1055</c26><c27>999</c27><c28>KH</c28><c29>24</c29><c30>KH</c30><c34>1390604985</c34><c42>19860510</c42><c45>6</c45><c48>KH0010116</c48><c52>NO</c52><c60>MRS</c60><c61>Test Data</c61><c62>Test Data</c62><c63>FEMALE</c63><c65>SINGLE</c65><c94>1390604985-</c94><c133>NULL</c133><c134>NULL</c134><c137>NULL</c137><c138>NULL</c138><c179>4</c179><c179 m=''2''>HS</c179><c179 m=''3''>21</c179><c179 m=''4''>2109</c179><c179 m=''5''>210912</c179><c179 m=''6''>21091205</c179><c179 m=''7''>123456</c179><c179 m=''19''>0976369092</c179><c179 m=''20''>Y</c179><c179 m=''22''>Test Data</c179><c179 m=''24''>Y</c179><c179 m=''25''>Y</c179><c179 m=''26''>N</c179><c179 m=''27''>N</c179><c179 m=''36''>20170105</c179><c179 m=''37''>I</c179><c179 m=''41''>1</c179><c179 m=''43''>3</c179><c179 m=''44''>4</c179><c179 m=''46''>1</c179><c179 m=''70''>Y</c179><c179 m=''71''>34</c179><c179 m=''72''>20221029</c179><c179 m=''77''>20170105</c179><c179 m=''79''>20170105</c179><c179 m=''89''>1</c179><c179 m=''125''>Y</c179><c179 m=''126''>Y</c179><c179 m=''127''>Y</c179><c179 m=''132''>N</c179><c179 m=''134''>N</c179><c179 m=''139''>N</c179><c179 m=''153''>N</c179><c179 m=''155''>03</c179><c179 m=''156''>0313</c179><c179 m=''157''>031303</c179><c179 m=''158''>03130317</c179><c179 m=''159''>N</c179><c179 m=''162''>N</c179><c179 m=''163''>N</c179><c179 m=''171''>0</c179><c179 m=''192''>19860505190604985</c179><c179 m=''200''></c179><c182>2</c182><c183>1188_USER_I_INAU_OFS_BROWSERTC</c183><c184>2106141532</c184><c184 m=''2''>2106141530</c184><c185>1188_USER</c185><c186>KH0010001</c186><c187>1</c187></row>') where a."RECID" = '1371523';'
      at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:211)
      at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:85)
      at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.parse(LogMinerQueryResultProcessor.java:281)
      ... 9 more

              Unassigned Unassigned
              sophany.san sophany san (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: