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

Support FLOAT(p) column definition style

    XMLWordPrintable

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

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            tamas.szasz Tamas Szasz (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: