Details
-
Task
-
Resolution: Done
-
Major
-
0.6
-
None
Description
If ROLLBACK TO savepoint is called then parsing exception is thrown
2017-10-25 15:46:57,240 ERROR BinlogReaderBufferIT||engine Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector' [io.debezium.connector.mysql.BinlogReaderBufferIT] org.apache.kafka.connect.errors.ConnectException: Expecting token type 128 at line 1, column 1 but found 'ROLLBACK': ===>> ROLLBACK TO `__71bb7 at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:178) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:156) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:404) at io.debezium.connector.mysql.EventBuffer.completeTransaction(EventBuffer.java:112) at io.debezium.connector.mysql.EventBuffer.add(EventBuffer.java:60) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1055) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:913) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:559) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:793) at java.lang.Thread.run(Thread.java:748) Caused by: io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'ROLLBACK': ===>> ROLLBACK TO `__71bb7 at io.debezium.text.TokenStream.consume(TokenStream.java:737) at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568) at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:168) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:359) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:534) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:391) ... 7 more