Loading...

Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: 1.9.0.CR1
Affects Version/s: 1.9.0.Alpha1
Component/s: oracle-connector
Labels:
- easy-starter

Blocked:
False
Blocked Reason:
None
Ready:
False
Target Release:

1.9.GA
Git Pull Request:
https://github.com/debezium/debezium/pull/3315
Steps to Reproduce:

Hide

NTLR Tool version 4.8 used for code generation does not match the current runtime version 4.9.2
ANTLR Runtime version 4.8 used for parser compilation does not match the current runtime version 4.9.2
ANTLR Tool version 4.8 used for code generation does not match the current runtime version 4.9.2
ANTLR Runtime version 4.8 used for parser compilation does not match the current runtime version 4.9.2
2022-03-17 07:56:08,768 ERROR [io.deb.con.ora.log.LogMinerHelper] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Mining session stopped due to the {}: java.lang.IllegalArgumentException: Unsupported column type: nclob
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52)
at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87)
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:311)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140)
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)

2022-03-17 07:56:08,769 ERROR [io.deb.pip.ErrorHandler] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Producer failure: java.lang.IllegalArgumentException: Unsupported column type: nclob
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52)
at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87)
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:311)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140)
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)

2022-03-17 07:56:08,769 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) startScn=4630911, endScn=4670499
2022-03-17 07:56:08,770 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Streaming metrics dump: OracleStreamingChangeEventSourceMetrics
{currentScn=4670499, oldestScn=4662957, committedScn=4663055, offsetScn=4630911, logMinerQueryCount=3, totalProcessedRows=69, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT20.074083S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT8.121991S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT8.121991S, totalBatchProcessingDuration=PT32.802898S, lastBatchProcessingDuration=PT5.717806S, maxBatchProcessingThroughput=0, currentLogFileName=[/opt/oracle/oradata/ORCLCDB/redo01.log], minLogFilesMined=1, maxLogFilesMined=1, redoLogStatus=[/opt/oracle/oradata/ORCLCDB/redo03.log | ACTIVE, /opt/oracle/oradata/ORCLCDB/redo02.log | ACTIVE, /opt/oracle/oradata/ORCLCDB/redo01.log | CURRENT], switchCounter=0, batchSize=20000, millisecondToSleepBetweenMiningQuery=1000, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT20.825855S, lastStartLogMiningSessionDuration=PT0.006981S, maxStartLogMiningSessionDuration=PT20.811734S, totalProcessTime=PT32.802898S, minBatchProcessTime=PT5.717806S, maxBatchProcessTime=PT27.085092S, totalResultSetNextTime=PT0.000078S, lagFromTheSource=DurationPT26.059482S, maxLagFromTheSourceDuration=PT43.973138S, minLagFromTheSourceDuration=PT26.057504S, lastCommitDuration=PT0.000027S, maxCommitDuration=PT0S, activeTransactions=1, rolledBackTransactions=0, committedTransactions=48, abandonedTransactionIds=[], rolledbackTransactionIds=[], registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=1048528, miningSessionUserGlobalAreaMaxMemory=1048528, miningSessionProcessGlobalAreaMemory=127869536, miningSessionProcessGlobalAreaMaxMemory=127869536}
2022-03-17 07:56:08,770 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Offsets: OracleOffsetContext [scn=4630911]
2022-03-17 07:56:08,770 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Finished streaming
2022-03-17 07:56:08,770 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Connected metrics set to 'false'
2022-03-17 07:56:08,993 INFO [io.deb.emb.EmbeddedEngine] (pool-7-thread-1) Stopping the task and engine
2022-03-17 07:56:08,993 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Stopping down connector
2022-03-17 07:56:09,012 INFO [io.deb.jdb.JdbcConnection] (pool-8-thread-1) Connection gracefully closed
2022-03-17 07:56:09,015 INFO [io.deb.ser.red.RedisOffsetBackingStore] (pool-7-thread-1) Stopped RedisOffsetBackingStore
2022-03-17 07:56:09,015 INFO [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector'', error = '{}': 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:192)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140)
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: java.lang.IllegalArgumentException: Unsupported column type: nclob
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91)
at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52)
at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java)
at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)
at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48)
at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36)
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87)
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:311)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559)
at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179)
... 9 more

Show
NTLR Tool version 4.8 used for code generation does not match the current runtime version 4.9.2 ANTLR Runtime version 4.8 used for parser compilation does not match the current runtime version 4.9.2 ANTLR Tool version 4.8 used for code generation does not match the current runtime version 4.9.2 ANTLR Runtime version 4.8 used for parser compilation does not match the current runtime version 4.9.2 2022-03-17 07:56:08,768 ERROR [io.deb.con.ora.log.LogMinerHelper] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Mining session stopped due to the {}: java.lang.IllegalArgumentException: Unsupported column type: nclob at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) 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:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140) 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) 2022-03-17 07:56:08,769 ERROR [io.deb.pip.ErrorHandler] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Producer failure: java.lang.IllegalArgumentException: Unsupported column type: nclob at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) 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:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140) 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) 2022-03-17 07:56:08,769 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) startScn=4630911, endScn=4670499 2022-03-17 07:56:08,770 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Streaming metrics dump: OracleStreamingChangeEventSourceMetrics {currentScn=4670499, oldestScn=4662957, committedScn=4663055, offsetScn=4630911, logMinerQueryCount=3, totalProcessedRows=69, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT20.074083S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT8.121991S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT8.121991S, totalBatchProcessingDuration=PT32.802898S, lastBatchProcessingDuration=PT5.717806S, maxBatchProcessingThroughput=0, currentLogFileName=[/opt/oracle/oradata/ORCLCDB/redo01.log], minLogFilesMined=1, maxLogFilesMined=1, redoLogStatus=[/opt/oracle/oradata/ORCLCDB/redo03.log | ACTIVE, /opt/oracle/oradata/ORCLCDB/redo02.log | ACTIVE, /opt/oracle/oradata/ORCLCDB/redo01.log | CURRENT], switchCounter=0, batchSize=20000, millisecondToSleepBetweenMiningQuery=1000, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT20.825855S, lastStartLogMiningSessionDuration=PT0.006981S, maxStartLogMiningSessionDuration=PT20.811734S, totalProcessTime=PT32.802898S, minBatchProcessTime=PT5.717806S, maxBatchProcessTime=PT27.085092S, totalResultSetNextTime=PT0.000078S, lagFromTheSource=DurationPT26.059482S, maxLagFromTheSourceDuration=PT43.973138S, minLagFromTheSourceDuration=PT26.057504S, lastCommitDuration=PT0.000027S, maxCommitDuration=PT0S, activeTransactions=1, rolledBackTransactions=0, committedTransactions=48, abandonedTransactionIds=[], rolledbackTransactionIds=[], registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=1048528, miningSessionUserGlobalAreaMaxMemory=1048528, miningSessionProcessGlobalAreaMemory=127869536, miningSessionProcessGlobalAreaMaxMemory=127869536} 2022-03-17 07:56:08,770 INFO [io.deb.con.ora.log.LogMinerStreamingChangeEventSource] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Offsets: OracleOffsetContext [scn=4630911] 2022-03-17 07:56:08,770 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Finished streaming 2022-03-17 07:56:08,770 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-oracleconnector-redislabs-change-event-source-coordinator) Connected metrics set to 'false' 2022-03-17 07:56:08,993 INFO [io.deb.emb.EmbeddedEngine] (pool-7-thread-1) Stopping the task and engine 2022-03-17 07:56:08,993 INFO [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Stopping down connector 2022-03-17 07:56:09,012 INFO [io.deb.jdb.JdbcConnection] (pool-8-thread-1) Connection gracefully closed 2022-03-17 07:56:09,015 INFO [io.deb.ser.red.RedisOffsetBackingStore] (pool-7-thread-1) Stopped RedisOffsetBackingStore 2022-03-17 07:56:09,015 INFO [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector'', error = '{}': 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:192) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:57) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:173) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:140) 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: java.lang.IllegalArgumentException: Unsupported column type: nclob at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:296) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:91) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:52) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:48) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:49) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:33) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:36) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) 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:311) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:559) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:278) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:242) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:188) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:179) ... 9 more

SFDC Cases Counter:
SFDC Cases Open:
SFDC Cases Links:

Create a table with nclob data type.
debezium is stopped and get an error message:Mining session stopped due to the {}: java.lang.IllegalArgumentException: Unsupported column type: nclob

Expect to get a warning message in case this datatype is not supported (as far as i see in the debezium documentation nclob datatype should be mapped). What about the other table fields? .

added the complete error message to the "the steps to reproduce"
tried to attach the file but couldn't

is related to

DBZ-4853 Debezium oracle connector stopped because of Unsupported column type: LONG

Closed

Details

Description

Attachments

Issue Links

Easy Agile Planning Poker

Activity

People

Dates