[2022-06-03 00:19:11,488] INFO [AdminClient clientId=adminclient-8] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient:935) the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484) [2022-06-03 05:02:50,851] ERROR [debezium-t3-boff-connector|task-0] Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:117) io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'alter table boff_item_jn set interval ( numtodsinterval ( 1, 'DAY' ) );' mismatched input 'interval' expecting 'UNUSED' 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.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.drop_column_clause(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.add_modify_drop_column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2399) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2087) 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:302) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:595) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:213) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:280) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:244) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:190) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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:829) Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.recoverInline(DefaultErrorStrategy.java:483) at org.antlr.v4.runtime.Parser.match(Parser.java:206) ... 27 more [2022-06-03 05:02:50,854] ERROR [debezium-t3-boff-connector|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:35) io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'alter table boff_item_jn set interval ( numtodsinterval ( 1, 'DAY' ) );' mismatched input 'interval' expecting 'UNUSED' 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.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.drop_column_clause(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.add_modify_drop_column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2399) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2087) 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:302) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:595) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:213) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:280) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:244) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:190) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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:829) Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.recoverInline(DefaultErrorStrategy.java:483) at org.antlr.v4.runtime.Parser.match(Parser.java:206) ... 27 more [2022-06-03 05:02:50,855] INFO [debezium-t3-boff-connector|task-0] startScn=7459130162655, endScn=7459130249109 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:225) [2022-06-03 05:02:50,855] INFO [debezium-t3-boff-connector|task-0] Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=7459130249109, oldestScn=7459130051783, committedScn=7459130197496, offsetScn=7459130051782, logMinerQueryCount=495, totalProcessedRows=16983496, totalCapturedDmlCount=461163, totalDurationOfFetchingQuery=PT1H19M2.777219S, lastCapturedDmlCount=289, lastDurationOfFetchingQuery=PT12.71706S, maxCapturedDmlCount=54235, maxDurationOfFetchingQuery=PT21.531153S, totalBatchProcessingDuration=PT6H53M51.05536S, lastBatchProcessingDuration=PT1M1.828091S, maxBatchProcessingThroughput=369, currentLogFileName=[/ora/orareco/TEBOFF31AZ1/onlinelog/o1_mf_3_hrmg7vdm_.log, /ora/oradata/TEBOFF31AZ1/onlinelog/o1_mf_3_hrmg7sx7_.log], minLogFilesMined=2, maxLogFilesMined=2, redoLogStatus=[/ora/oradata/TEBOFF31AZ1/onlinelog/o1_mf_2_hrmg7pwl_.log | ACTIVE, /ora/oradata/TEBOFF31AZ1/onlinelog/o1_mf_1_hrmg7mqk_.log | ACTIVE, /ora/orareco/TEBOFF31AZ1/onlinelog/o1_mf_1_hrmg7o2q_.log | ACTIVE, /ora/orareco/TEBOFF31AZ1/onlinelog/o1_mf_2_hrmg7r85_.log | ACTIVE, /ora/orareco/TEBOFF31AZ1/onlinelog/o1_mf_3_hrmg7vdm_.log | CURRENT, /ora/oradata/TEBOFF31AZ1/onlinelog/o1_mf_3_hrmg7sx7_.log | CURRENT], switchCounter=1534, batchSize=100000, millisecondToSleepBetweenMiningQuery=2800, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=100000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT24.059643S, totalStartLogMiningSessionDuration=PT2H34M32.566405S, lastStartLogMiningSessionDuration=PT23.886926S, maxStartLogMiningSessionDuration=PT38.851841S, totalProcessTime=PT6H53M51.05536S, minBatchProcessTime=PT35.528122S, maxBatchProcessTime=PT2M53.836623S, totalResultSetNextTime=PT1H12M39.833838S, lagFromTheSource=DurationPT1M18.377908S, maxLagFromTheSourceDuration=PT44M49.790296S, minLagFromTheSourceDuration=PT36.261407S, lastCommitDuration=PT0.00015S, maxCommitDuration=PT1.247447S, activeTransactions=10, rolledBackTransactions=118656, committedTransactions=7689593, abandonedTransactionIds={}, rolledbackTransactionIds={21001b000c5a0e00=21001b000c5a0e00, 07001e00c7c96f00=07001e00c7c96f00, 0c001700eeda6100=0c001700eeda6100, 05000d00897d6b00=05000d00897d6b00, 1e00160015e01500=1e00160015e01500, 09000400dec57700=09000400dec57700, 0c000600d0bd6100=0c000600d0bd6100, 15001e001dab3f00=15001e001dab3f00, 0a001f00e8498300=0a001f00e8498300, 16000000f9423b00=16000000f9423b00}, registeredDmlCount=418356, committedDmlCount=362164, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=62418920, miningSessionUserGlobalAreaMaxMemory=92563560, miningSessionProcessGlobalAreaMemory=113197576, miningSessionProcessGlobalAreaMaxMemory=133775880} (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:226) [2022-06-03 05:02:50,855] INFO [debezium-t3-boff-connector|task-0] Offsets: OracleOffsetContext [scn=7459130051782, commit_scn=7459130197499] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:227) [2022-06-03 05:02:50,855] INFO [debezium-t3-boff-connector|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:175) [2022-06-03 05:02:50,856] INFO [debezium-t3-boff-connector|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:236) [2022-06-03 05:02:51,076] INFO [debezium-t3-boff-connector|task-0] WorkerSourceTask{id=debezium-t3-boff-connector-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask:484) [2022-06-03 05:02:51,155] ERROR [debezium-t3-boff-connector|task-0] WorkerSourceTask{id=debezium-t3-boff-connector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:195) 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:50) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:222) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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:829) Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'alter table boff_item_jn set interval ( numtodsinterval ( 1, 'DAY' ) );' mismatched input 'interval' expecting 'UNUSED' 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.reportInputMismatch(DefaultErrorStrategy.java:327) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.drop_column_clause(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.add_modify_drop_column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.column_clauses(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.alter_table(PlSqlParser.java) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2399) at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2087) 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:302) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:595) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:213) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:280) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:244) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:190) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) ... 9 more Caused by: org.antlr.v4.runtime.InputMismatchException at org.antlr.v4.runtime.DefaultErrorStrategy.recoverInline(DefaultErrorStrategy.java:483) at org.antlr.v4.runtime.Parser.match(Parser.java:206) ... 27 more