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

Mysql connector failed to parse add partition statement

    XMLWordPrintable

Details

    Description

      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
      

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: