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

ROLLBACK to savepoint cannot be parsed

    XMLWordPrintable

Details

    • Task
    • Resolution: Done
    • Major
    • 0.7.2
    • 0.6
    • mysql-connector
    • 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
      

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            jpechane Jiri Pechanec
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: