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

Support FLOAT(p) column definition style

    Details

      Description

      When running Kafka Connect with the debezium plugin and using mysql-connector to fetch data from Amazon Aurora, we are getting the following error:

      [2019-04-08 19:38:55,119] ERROR WorkerSourceTask{id=mysql-source-connector-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask)
      org.apache.kafka.connect.errors.ConnectException: no viable alternative at input 'CREATE TABLE `call_network_healths` (`id` int(11) auto_increment PRIMARY KEY, `agent_id` int(11), `bitrate` float(24)'
          at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
          at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
          at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:486)
          at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
          at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
          at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
          at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
          at java.lang.Thread.run(Thread.java:748)
      Caused by: io.debezium.text.ParsingException: no viable alternative at input 'CREATE TABLE `call_network_healths` (`id` int(11) auto_increment PRIMARY KEY, `agent_id` int(11), `bitrate` float(24)'
          at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:40)
          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:282)
          at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:121)
          at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1076)
          at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:810)
          at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:71)
          at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:44)
          at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80)
          at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:306)
          at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:672)
          at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:470)
          ... 5 more
      Caused by: org.antlr.v4.runtime.NoViableAltException
          at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2023)
          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.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:884)
          ... 12 more
      [2019-04-08 19:38:55,119] ERROR WorkerSourceTask{id=mysql-source-connector-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask)
      

      Restarting the task does not help to fix the problem.
      After downgrading back to 0.8.3 Final, the problem seems to be gone

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                jpechanec Jiri Pechanec
                Reporter:
                tamas.szasz Tamas Szasz
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: