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

Can't parse create definition on the mysql connector

    Details

      Description

      Similar to https://issues.jboss.org/browse/DBZ-903 and https://issues.jboss.org/browse/DBZ-910

      Error while parsing DDL:

      "2019-06-21 06:03:48,524 ERROR WorkerSourceTask{id=com.nutmeg.portfolio.cdc-fund-details-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask) [pool-5-thread-1]
      org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: no viable alternative at input 'CREATE TABLE USER\
      (\
        UUID VARCHAR(36) NOT NULL PRIMARY KEY,\
        EMAIL VARCHAR(256) NOT NULL ,\
        INTERNAL'
      \tat io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:275)
      \tat io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:49)
      \tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:198)
      \tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
      \tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
      \tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      \tat java.util.concurrent.FutureTask.run(FutureTask.java:266)
      \tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      \tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      \tat java.lang.Thread.run(Thread.java:748)
      Caused by: io.debezium.text.ParsingException: no viable alternative at input 'CREATE TABLE USER\
      (\
        UUID VARCHAR(36) NOT NULL PRIMARY KEY,\
        EMAIL VARCHAR(256) NOT NULL ,\
        INTERNAL'
      \tat io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:40)
      \tat org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
      \tat org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
      \tat org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:282)
      \tat org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:121)
      \tat io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1078)
      \tat io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:812)
      \tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:68)
      \tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:41)
      \tat io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80)
      \tat io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:104)
      \tat io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:240)
      \tat io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:73)
      \tat io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:252)
      \tat io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:165)
      \tat io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:105)
      \t... 9 more
      Caused by: org.antlr.v4.runtime.NoViableAltException
      \tat org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2023)
      \tat org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
      \tat org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
      \tat io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:886)
      \t... 19 more"
      

      Offending DDL statement:

      CREATE TABLE USER
      (
        UUID VARCHAR(36) NOT NULL PRIMARY KEY,
        EMAIL VARCHAR(256) NOT NULL ,
        INTERNAL BOOLEAN DEFAULT FALSE,
        INDEX IDX_USER_1 (EMAIL)
      ) ENGINE=InnoDB DEFAULT CHARSET=latin1
      

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                jpechanec Jiri Pechanec
                Reporter:
                javierholguera Javier Holguera
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: