[2022-03-11 03:50:15,520] DEBUG Transaction 143207006d2f0000 has already been processed. Offset Commit SCN 18182917204127, Tranasction Commit SCN 18182917204091, Last Seen Commit SCN null. (io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor:339) [2022-03-11 03:50:15,520] DEBUG Transaction 4c010d000f2f0000 has already been processed. Offset Commit SCN 18182917204127, Tranasction Commit SCN 18182917204094, Last Seen Commit SCN null. (io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor:339) [2022-03-11 03:50:15,599] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-03-11 03:50:15,602] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-03-11 03:50:15,604] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-03-11 03:50:15,604] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:111) io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE WBXCRLOG ( CRID NUMBER not null, CONFLICTTIME DATE default SYSDATE, CONFLICTRESOLVED VARCHAR2(1) not null, CONFLICTCHECKED VARCHAR2(1) not null, ORACLEERR NUMBER, SRCHOST VARCHAR2(32), SRCORASID VARCHAR2(32), SOURCEROWID VARCHAR2(20), TARGETROWID VARCHAR2(20), CONFLICTTABLE VARCHAR2(100), CONFLICTTYPE VARCHAR2(1), PRIMARYKEYS VARCHAR2(4000), MESSAGE VARCHAR2(600), ERRSQLCODE VARCHAR2(200), ERROMESSAGE VARCHAR2(500), SQLSTATEMENT CLOB, COMMENTS VARCHAR2(200), CONSTRAINT PK_WBXCRLOG PRIMARY KEY(CONFLICTTIME,CRID) USING INDEX TABLESPACE SPLEX_INDX LOCAL ) PARTITION BY RANGE(CONFLICTTIME) INTERVAL(NUMTOYMINTERVAL(1, 'MONTH')) STORE IN (SPLEX_DATA) ( PARTITION P201805 VALUES LESS THAN (TO_DATE('2018-06-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA, PARTITION P201806 VALUES LESS THAN (TO_DATE('2018-07-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA );' extraneous input 'LOCAL' expecting {')', ','} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:377) at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:275) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:51221) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49531) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2435) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:73) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:68) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:85) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:308) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:547) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:187) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:268) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:240) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:186) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:168) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2022-03-11 03:50:15,605] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31) io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE WBXCRLOG ( CRID NUMBER not null, CONFLICTTIME DATE default SYSDATE, CONFLICTRESOLVED VARCHAR2(1) not null, CONFLICTCHECKED VARCHAR2(1) not null, ORACLEERR NUMBER, SRCHOST VARCHAR2(32), SRCORASID VARCHAR2(32), SOURCEROWID VARCHAR2(20), TARGETROWID VARCHAR2(20), CONFLICTTABLE VARCHAR2(100), CONFLICTTYPE VARCHAR2(1), PRIMARYKEYS VARCHAR2(4000), MESSAGE VARCHAR2(600), ERRSQLCODE VARCHAR2(200), ERROMESSAGE VARCHAR2(500), SQLSTATEMENT CLOB, COMMENTS VARCHAR2(200), CONSTRAINT PK_WBXCRLOG PRIMARY KEY(CONFLICTTIME,CRID) USING INDEX TABLESPACE SPLEX_INDX LOCAL ) PARTITION BY RANGE(CONFLICTTIME) INTERVAL(NUMTOYMINTERVAL(1, 'MONTH')) STORE IN (SPLEX_DATA) ( PARTITION P201805 VALUES LESS THAN (TO_DATE('2018-06-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA, PARTITION P201806 VALUES LESS THAN (TO_DATE('2018-07-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA );' extraneous input 'LOCAL' expecting {')', ','} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:377) at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:275) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:51221) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49531) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2435) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:73) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:68) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:85) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:308) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:547) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:187) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:268) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:240) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:186) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:168) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2022-03-11 03:50:15,605] INFO startScn=18182917190759, endScn=18182917220759 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:184) [2022-03-11 03:50:15,605] INFO Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=18182968119324, oldestScn=18182917171160, committedScn=18182917207628, offsetScn=18182917171159, logMinerQueryCount=2, totalProcessedRows=7209, totalCapturedDmlCount=3642, totalDurationOfFetchingQuery=PT14.823S, lastCapturedDmlCount=3642, lastDurationOfFetchingQuery=PT8.852S, maxCapturedDmlCount=3642, maxDurationOfFetchingQuery=PT8.852S, totalBatchProcessingDuration=PT6.22S, lastBatchProcessingDuration=PT6.22S, maxBatchProcessingThroughput=586, currentLogFileName=[+DG_REDO/idprdam/redo05.log, +DG_REDO/idprdam/redo01.log], minLogFilesMined=2, maxLogFilesMined=2, redoLogStatus=[+DG_REDO/idprdam/redo04.log | ACTIVE, +DG_REDO/idprdam/redo01.log | CURRENT, +DG_REDO/idprdam/redo05.log | CURRENT, +DG_REDO/idprdam/redo08.log | INACTIVE, +DG_REDO/idprdam/redo02.log | INACTIVE, +DG_REDO/idprdam/redo06.log | INACTIVE, +DG_REDO/idprdam/redo07.log | INACTIVE, +DG_REDO/idprdam/redo03.log | INACTIVE], switchCounter=0, batchSize=40000, millisecondToSleepBetweenMiningQuery=160, hoursToKeepTransaction=1, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=10000, batchSizeMax=200000, sleepTimeDefault=200, sleepTimeMin=40, sleepTimeMax=1000, sleepTimeIncrement=20, totalParseTime=PT0.058S, totalStartLogMiningSessionDuration=PT0.009S, lastStartLogMiningSessionDuration=PT0.004S, maxStartLogMiningSessionDuration=PT0.005S, totalProcessTime=PT6.22S, minBatchProcessTime=PT6.22S, maxBatchProcessTime=PT6.22S, totalResultSetNextTime=PT0.001S, lagFromTheSource=DurationPT15H28M51.589S, maxLagFromTheSourceDuration=PT15H29M3.137S, minLagFromTheSourceDuration=PT15H28M51.334S, lastCommitDuration=PT0S, maxCommitDuration=PT0.001S, activeTransactions=7, rolledBackTransactions=4, committedTransactions=498, abandonedTransactionIds=[], rolledbackTransactionIds=[7b260d00ef110000, 98181e005c320000, f4191b0008100000, bc2e12005e300000], registeredDmlCount=6237, committedDmlCount=666, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=4749912, miningSessionUserGlobalAreaMaxMemory=4749912, miningSessionProcessGlobalAreaMemory=11158648, miningSessionProcessGlobalAreaMaxMemory=11158648} (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:185) [2022-03-11 03:50:15,605] INFO Offsets: OracleOffsetContext [scn=18182917171159] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:186) [2022-03-11 03:50:15,605] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:173) [2022-03-11 03:50:15,605] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:70) [2022-03-11 03:50:15,870] INFO WorkerSourceTask{id=debezium-PROD-ams-0125-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-03-11 03:50:15,870] INFO WorkerSourceTask{id=debezium-PROD-ams-0125-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-03-11 03:50:15,871] ERROR WorkerSourceTask{id=debezium-PROD-ams-0125-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:187) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:181) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE WBXCRLOG ( CRID NUMBER not null, CONFLICTTIME DATE default SYSDATE, CONFLICTRESOLVED VARCHAR2(1) not null, CONFLICTCHECKED VARCHAR2(1) not null, ORACLEERR NUMBER, SRCHOST VARCHAR2(32), SRCORASID VARCHAR2(32), SOURCEROWID VARCHAR2(20), TARGETROWID VARCHAR2(20), CONFLICTTABLE VARCHAR2(100), CONFLICTTYPE VARCHAR2(1), PRIMARYKEYS VARCHAR2(4000), MESSAGE VARCHAR2(600), ERRSQLCODE VARCHAR2(200), ERROMESSAGE VARCHAR2(500), SQLSTATEMENT CLOB, COMMENTS VARCHAR2(200), CONSTRAINT PK_WBXCRLOG PRIMARY KEY(CONFLICTTIME,CRID) USING INDEX TABLESPACE SPLEX_INDX LOCAL ) PARTITION BY RANGE(CONFLICTTIME) INTERVAL(NUMTOYMINTERVAL(1, 'MONTH')) STORE IN (SPLEX_DATA) ( PARTITION P201805 VALUES LESS THAN (TO_DATE('2018-06-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA, PARTITION P201806 VALUES LESS THAN (TO_DATE('2018-07-01', 'YYYY-MM-DD')) TABLESPACE SPLEX_DATA );' extraneous input 'LOCAL' expecting {')', ','} at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:377) at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:275) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:51221) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49531) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2435) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2007) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:73) at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:68) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:85) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:308) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:547) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:187) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:268) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:240) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:186) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:168) ... 9 more [2022-03-11 03:50:15,871] ERROR WorkerSourceTask{id=debezium-PROD-ams-0125-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:188) [2022-03-11 03:50:15,871] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:238) [2022-03-11 03:50:15,875] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-03-11 03:50:15,875] INFO [Producer clientId=idstore-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1189) [2022-03-11 03:50:15,877] INFO [Producer clientId=connector-producer-debezium-PROD-ams-0125-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1189) [2022-03-11 03:50:15,878] INFO Close ColumnBasedPartitioner (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:148) [2022-03-11 03:50:17,929] INFO WorkerSourceTask{id=debezium-PROD-ams-0125-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-03-11 03:50:17,929] INFO WorkerSourceTask{id=debezium-PROD-ams-0125-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495)