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

Mysql connector failed to parse add partition statement

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 0.9.0.Beta1
    • 0.7.5
    • mysql-connector
    • None

      org.apache.kafka.connect.errors.ConnectException: Failed to parse statement 'ALTER TABLE ***.**** ADD  PARTITION(PARTITION  p201901 VALUES LESS THAN (737425) ENGINE = InnoDB)'
          at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:200)
          at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:178)
          at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:444)
          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:745)
      Caused by: io.debezium.text.ParsingException: Failed to parse statement 'ALTER TABLE ***.**** ADD  PARTITION(PARTITION  p201901 VALUES LESS THAN (737425) ENGINE = InnoDB)'
          at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:292)
          at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)
          at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:322)
          at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:615)
          at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:428)
          ... 5 more
      

              jpechane Jiri Pechanec
              artiship artiship artiship (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: