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

DDL statement couldn't be parsed

    XMLWordPrintable

Details

    Description

      We are using the stable version 1.6

      Error:

      [2021-07-14 10:28:49,029] INFO DDL: transactionId=03002000c5093f00, SCN=10360970425182, table_name=ESHP_AUCTION_FILE_HISTORY, segOwner=ESHOP, operationCode=5, offsetSCN=10360970421492,  commitOffsetSCN=10360970422971, REDO_SQL: create table eshp_auction_file_history (
                       history_id number not null,
                       history_date timestamp not null,
                       auction_id number not null,
                       changed_by varchar(4000),
                       type varchar(4000) not null,
                       constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                       constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
                  ); (io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor:164)
      [2021-07-14 10:28:49,030] INFO KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=eaistdev-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=10.241.25.71:8091,10.241.25.71:8092,10.241.25.72:8091,10.241.25.72:8092, client.id=eaistdev-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:215)
      [2021-07-14 10:28:49,030] INFO KafkaDatabaseHistory Producer config: {bootstrap.servers=10.241.25.71:8091,10.241.25.71:8092,10.241.25.72:8091,10.241.25.72:8092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=eaistdev-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:216)
      [2021-07-14 10:28:49,030] INFO Requested thread factory for connector OracleConnector, id = eaistdev named = db-history-config-check (io.debezium.util.Threads:270)
      [2021-07-14 10:28:49,160] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:506)
      io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table eshp_auction_file_history (
                       history_id number not null,
                       history_date timestamp not null,
                       auction_id number not null,
                       changed_by varchar(4000),
                       type varchar(4000) not null,
                       constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                       constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
                  );'
      no viable alternative at input 'eshp_auction_file_history(history_id))'
              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.reportNoViableAlternative(DefaultErrorStrategy.java:310)
              at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_index(PlSqlParser.java:15121)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.using_index_clause(PlSqlParser.java)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.constraint_state(PlSqlParser.java:41615)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.out_of_line_constraint(PlSqlParser.java:41434)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_property(PlSqlParser.java:50999)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:50746)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49072)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2421)
              at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68)
              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:63)
              at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81)
              at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:297)
              at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:169)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:184)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:63)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
              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: org.antlr.v4.runtime.NoViableAltException
              at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026)
              at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
              at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_index(PlSqlParser.java:15085)
              ... 23 more
      io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table eshp_auction_file_history (
                       history_id number not null,
                       history_date timestamp not null,
                       auction_id number not null,
                       changed_by varchar(4000),
                       type varchar(4000) not null,
                       constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                       constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
                  );'
      mismatched input ',' expecting {'AS', ';'}
              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.create_table(PlSqlParser.java:49106)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2421)
              at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68)
              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:63)
              at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81)
              at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:297)
              at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:169)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:184)
              at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:63)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
              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: org.antlr.v4.runtime.InputMismatchException
              at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270)
              at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49089)
              ... 17 more
      
      

      connector config:

      {'name': 'oracle_logminer_140721-1341', 'config': {'connector.class': 'io.debezium.connector.oracle.OracleConnector', 'tasks.max': '1', 'snapshot.mode': 'schema_only', 'snapshot.delay.ms': '10000', 'provide.transaction.metadata': 'true', 'decimal.handling.mode': 'string', 'sanitize.field.names': 'true', 'event.processing.failure.handling.mode': 'skip', 'database.history.kafka.bootstrap.servers': '...', 'database.history.kafka.topic': 'history_oracle_logminer_140721-1341', 'snapshot.locking.mode': 'none', 'log.mining.transaction.retention.hours': '1', 'table.include.list': 'ABCD_SHARD_1_3.D_LOT_VERSION,ABCD_SHARD_1_3.D_LOT_ENTITY,ABCD_SHARD_1_3.D_LOT_STATUS_HISTORY,ABCD_SHARD_1_3.D_PROCEDURE_LOT_ENTRY,ABCD_SHARD_1_3.D_LOT_LOT_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_VERSION,ABCD_SHARD_1_3.D_PROCEDURE_ENTITY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_LOT_ENTRY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_VERSION,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_ENTITY,ABCD_SHARD_1_3.D_BID,ABCD_SHARD_1_3.D_EA_PARTICIPANT,ABCD_SHARD_1_3.D_LOT_LOTNUM_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_STATUS_HISTORY,ABCD_SHARD_1_3.D_OOS_EXCHANGE_PROTOCOL,ABCD_SHARD_1_3.D_PROCEDURE_DATE,ABCD_SHARD_1_3.D_OOS_FTP_PROTOCOL,ABCD_SHARD_1_3.D_COMMISSION_SESSION,ABCD_SHARD_1_3.D_LOT_NMC,ABCD_SHARD_1_3.D_LOT_NMC_EXAMINATION,ABCD_NSI.N_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ,ABCD_NSI.N_SPGZ_CHARACTERISTIC_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ_ENUM,ABCD_NSI.N_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ,ABCD_NSI.N_KPGZ_CHARACTERISTIC_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ_ENUM,ABCD_NSI.N_KPGZ_CONTRACT_TEMPLATE,ABCD_NSI.N_KPGZ_TECH_TASK,ABCD_NSI.N_CHARACTERISTIC,ABCD_NSI.N_OKEI_SPGZ', 'database.server.name': 'ABCDdev', 'database.hostname': '...', 'rac.node': '', 'database.port': '1521', 'database.user': 'xstrm', 'database.password': 'xstrm', 'database.dbname': 'ABCDdev'}}
      

      Attachments

        Activity

          People

            ccranfor@redhat.com Chris Cranford
            chapeauclaque Dmitriy Rum (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: