-
Bug
-
Resolution: Duplicate
-
Major
-
None
-
1.5.4.Final, 1.6.0.Final
-
None
-
False
-
False
-
Undefined
-
-
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