Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: 1.9.1.Final, 2.0.0.Alpha1
Affects Version/s: 1.9.0.Final
Component/s: oracle-connector
Labels:
None

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

1.9.GA
Steps to Reproduce:
Hide

alter table testtable modify testcol default 0;
Show
alter table testtable modify testcol default 0;

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

reason sql: alter table testtable modify testcol default 0;

the sql worked well on oracle , and debezium raised an exception.

Bug report

[2022-04-11 17:01:23,000] ERROR WorkerSourceTask{id=oracle-extract-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:190)
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.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:128)
        at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
        at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
        at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108)
        at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43)
        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.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NullPointerException
        at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:306)
        at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:98)
        at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterModify_col_properties(ColumnDefinitionParserListener.java:71)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Modify_col_propertiesContext.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:41)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)
        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:310)
        at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchSchemaChangeEvent(LcrEventHandler.java:235)
        at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:118)
        ... 12 more
[2022-04-11 17:01:23,001] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:238)

What Debezium connector do you use and what version?

oracle-connector 1.9.0.Final

What is the connector configuration?

{
"name": "test001-oracle-extract",
"config":

{ "connector.class": "io.debezium.connector.oracle.OracleConnector", "db_type": "oracle", "snapshot.locking.mode": "none", "tasks.max": "1", "database.history.kafka.topic": "test001-ods-his", "transforms": "Reroute", "database.tablename.case.insensitive": "true", "log.mining.strategy": "online_catalog", "include.schema.changes": "true", "transforms.Reroute.topic.replacement": "test001-ods", "decimal.handling.mode": "string", "database.history.skip.unparseable.ddl": "true", "database.out.server.name": "dbzxout", "database.history.store.only.captured.tables.ddl": "true", "database.oracle.version": "11", "errors.log.enable": "true", "database.user": "tdhextract", "database.dbname": "orcl", "transforms.Reroute.type": "io.debezium.transforms.ByLogicalTableRouter", "database.connection.adapter": "xstream", "database.history.kafka.bootstrap.servers": "test001:9092", "database.server.name": "test001", "transforms.Reroute.topic.regex": "(.*)", "database.port": "1521", "database.hostname": "192.168.1.2", "database.password": "123456", "name": "test001-oracle-extract", "table.include.list": "testuser.testtable", "snapshot.mode": "schema_only" }

,
"tasks": [

{ "connector": "test001-oracle-extract", "task": 0 }

],
"type": "source"
}

What is the captured database version and mode of depoyment?

oracle 11g xstream

is related to

DBZ-4992 ANTLR sql files doesn't raise error in case incorrect DDL

Closed

Details

Description

Bug report

What Debezium connector do you use and what version?

What is the connector configuration?

What is the captured database version and mode of depoyment?

Attachments

Issue Links

Easy Agile Planning Poker

Activity

People

Dates