[2024-04-19 15:14:04,687] WARN [connector|task-0] An unsupported operation detected for table 'tbl' in transaction 0500120015088c00 with SCN 456768975832 on redo thread 0. (io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor:1152) [2024-04-19 15:14:04,690] ERROR [connector|task-0] Mining session stopped due to error. (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:265) io.debezium.connector.oracle.logminer.parser.DmlParserException: DML statement couldn't be parsed. Please open a Jira issue with the statement 'update tbl set "POLE2" = 'privet2' where "col1" = 'val1' ..a lot of conditions... and "POLE1" = 'privet' and "POLE2" IS NULL;'. at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1409) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.lambda$handleDataEvent$11(AbstractLogMinerEventProcessor.java:1138) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.addToTransaction(MemoryLogMinerEventProcessor.java:205) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleDataEvent(AbstractLogMinerEventProcessor.java:1137) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:424) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:320) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:241) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:246) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:61) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:280) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:140) 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 tbl set "POLE2" = 'privet2' where "col1" = 'val1' ..a lot of conditions... and "POLE1" = 'privet' and "POLE2" IS NULL;' at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:166) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:75) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1403) ... 16 more Caused by: io.debezium.DebeziumException: No column 'POLE2' found in table 'tbl' at io.debezium.connector.oracle.logminer.LogMinerHelper.getColumnIndexByName(LogMinerHelper.java:26) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.getColumnIndexByName(LogMinerDmlParser.java:91) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseSetClause(LogMinerDmlParser.java:437) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:141) ... 18 more [2024-04-19 15:14:04,695] ERROR [connector|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52) io.debezium.connector.oracle.logminer.parser.DmlParserException: DML statement couldn't be parsed. Please open a Jira issue with the statement 'update tbl set "POLE2" = 'privet2' where "col1" = 'val1' ..a lot of conditions... AND "POLE1" = 'privet' and "POLE2" IS NULL;'. at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1409) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.lambda$handleDataEvent$11(AbstractLogMinerEventProcessor.java:1138) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.addToTransaction(MemoryLogMinerEventProcessor.java:205) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleDataEvent(AbstractLogMinerEventProcessor.java:1137) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:424) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:320) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:241) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:246) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:61) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:280) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:140) 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 tbl set "POLE2" = 'privet2' where "col1" = 'val1' ..a lot of conditions... and "POLE1" = 'privet' and "POLE2" IS NULL;' at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:166) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:75) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1403) ... 16 more Caused by: io.debezium.DebeziumException: No column 'POLE2' found in table 'tbl' at io.debezium.connector.oracle.logminer.LogMinerHelper.getColumnIndexByName(LogMinerHelper.java:26) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.getColumnIndexByName(LogMinerDmlParser.java:91) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseSetClause(LogMinerDmlParser.java:437) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:141) ... 18 more [2024-04-19 15:14:04,719] INFO [connector|task-0] startScn=456768975831, endScn=456768987354 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:270) [2024-04-19 15:14:04,719] INFO [connector|task-0] Streaming metrics dump: LogMinerStreamingChangeEventSourceMetrics{connectorConfig=io.debezium.connector.oracle.OracleConnectorConfig@306600b9, startTime=2024-04-19T12:04:16.956151Z, clock=SystemClock[Z], currentScn=456768987354, offsetScn=456768971297, commitScn=456768975831, oldestScn=-1, oldestScnTime=null, currentLogFileNames=[Ljava.lang.String;@6723a544, redoLogStatuses=[Ljava.lang.String;@48d3c5e0, databaseZoneOffset=+03:00, batchSize=20000, logSwitchCount=0, logMinerQueryCount=148, sleepTime=3000, minimumLogsMined=1, maximumLogsMined=1, maxBatchProcessingThroughput=1316, timeDifference=1, processedRowsCount=106216, activeTransactionCount=0, rolledBackTransactionCount=18, oversizedTransactionCount=0, changesCount=100998, scnFreezeCount=0, batchProcessingDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@65eada82, fetchQueryDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@65896d4e, commitDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@1ffafd3e, lagFromSourceDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@4950d7e4, miningSessionStartupDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@7add3a86, parseTimeDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@5490cb8e, resultSetNextDuration=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$DurationHistogramMetric@1ccbcf2f, userGlobalAreaMemory=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$MaxLongValueMetric@536bc4a5, processGlobalAreaMemory=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$MaxLongValueMetric@40f1dd44, abandonedTransactionIds=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$LRUSet@126fa26f, rolledBackTransactionIds=io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics$LRUSet@501fa5ba} io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSourceMetrics@403c6d8d (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:271) [2024-04-19 15:14:04,720] INFO [connector|task-0] Offsets: OracleOffsetContext [scn=456768975831, commit_scn=["456768975831:1:0a001000ed755a00"], lcr_position=null] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:272) [2024-04-19 15:14:04,720] INFO [connector|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:281) [2024-04-19 15:14:04,720] INFO [connector|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:433) [2024-04-19 15:14:04,861] ERROR [connector|task-0] WorkerSourceTask{id=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:67) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:267) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:61) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:280) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:140) 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: DML statement couldn't be parsed. Please open a Jira issue with the statement 'update tbl set "POLE2" = 'privet2' ..a lot of conditions... where "col1" = 'val1' and "POLE1" = 'privet' and "POLE2" IS NULL;'. at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1409) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.lambda$handleDataEvent$11(AbstractLogMinerEventProcessor.java:1138) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.addToTransaction(MemoryLogMinerEventProcessor.java:205) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleDataEvent(AbstractLogMinerEventProcessor.java:1137) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:424) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:320) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:241) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:246) ... 9 more Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: Failed to parse update DML: 'update tbl set "POLE2" = 'privet2' where "col1" = 'val1' ..a lot of conditions... and "POLE1" = 'privet' and "POLE2" IS NULL;' at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:166) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:75) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1403) ... 16 more Caused by: io.debezium.DebeziumException: No column 'POLE2' found in table 'tbl' at io.debezium.connector.oracle.logminer.LogMinerHelper.getColumnIndexByName(LogMinerHelper.java:26) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.getColumnIndexByName(LogMinerDmlParser.java:91) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseSetClause(LogMinerDmlParser.java:437) at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseUpdate(LogMinerDmlParser.java:141) ... 18 more [2024-04-19 15:14:04,864] INFO [connector|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:398) [2024-04-19 15:14:04,864] INFO [connector|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:127) [2024-04-19 15:14:04,864] INFO [connector|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105) [2024-04-19 15:14:04,891] INFO [connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:952) [2024-04-19 15:14:04,899] INFO [connector|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:952) [2024-04-19 15:14:04,900] INFO [connector|task-0] [Producer clientId=topic] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1249) [2024-04-19 15:14:04,902] INFO [connector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2024-04-19 15:14:04,902] INFO [connector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2024-04-19 15:14:04,902] INFO [connector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2024-04-19 15:14:04,902] INFO [connector|task-0] App info kafka.producer for SBLDB07_hybrid-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-04-19 15:14:04,903] INFO [connector|task-0] [Producer clientId=connector-producer-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1249) [2024-04-19 15:14:04,905] INFO [connector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2024-04-19 15:14:04,905] INFO [connector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2024-04-19 15:14:04,905] INFO [connector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2024-04-19 15:14:04,906] INFO [connector|task-0] App info kafka.producer for connector-producer-connector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-04-19 15:14:04,906] INFO [connector|task-0] App info kafka.admin.client for connector-adminclient-connector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2024-04-19 15:14:04,907] INFO [connector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2024-04-19 15:14:04,907] INFO [connector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2024-04-19 15:14:04,907] INFO [connector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2024-04-19 15:14:17,008] INFO [AdminClient clientId=adminclient-8] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient:935) [2024-04-19 15:14:34,934] INFO [Producer clientId=producer-2] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient:935)