Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4880

oracle connector fails because of unsupported column type nclob

    XMLWordPrintable

Details

    • False
    • None
    • False
    • 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

    Description

      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

      Attachments

        Issue Links

          Activity

            People

              ccranfor@redhat.com Chris Cranford
              gali.levin gal levin
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: