Details
-
Bug
-
Resolution: Done
-
Major
-
0.9.3.Final
-
None
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
