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

DDL statement couldn't be parsed for ROW_FORMAT=TOKUDB_QUICKLZ

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Minor Minor
    • 1.5.0.CR1
    • None
    • mysql-connector
    • None

      Debezium connector for MySQL failing when parsing DDL.

      We are currently using Debezium version 1.4.2.Final

      innodb_version=5.7.26-29

      mysql version=5.7.26-29-log

      "trace": "org.apache.kafka.connect.errors.ConnectException: Encountered change event for table searchjobdb.tblSRCHjob_desc whose schema isn't known to this connector
              at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241)
              at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218)
              at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595)
              at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839)
              at java.lang.Thread.run(Thread.java:748)
            Caused by: org.apache.kafka.connect.errors.ConnectException: Encountered change event for table searchjobdb.tblSRCHjob_desc whose schema isn't known to this connector
              at io.debezium.connector.mysql.BinlogReader.informAboutUnknownTableIfRequired(BinlogReader.java:875)
              at io.debezium.connector.mysql.BinlogReader.handleUpdateTableMetadata(BinlogReader.java:849)
              at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590)
              ... 5 more
            "

       
      The offending DDL is:

      CREATE TABLE `tblSRCHjob_desc` (\n `description_id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,\n `description` mediumtext NOT NULL,\n PRIMARY KEY (`description_id`)\n) ENGINE=TokuDB AUTO_INCREMENT=4095997820 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=TOKUDB_QUICKLZ
      

              ccranfor@redhat.com Chris Cranford
              lnguyen-1 Luan Nguyen (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: