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

DDL containing text column with length specification cannot be parsed

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 0.6.2
    • 0.6.1
    • mysql-connector
    • None

      2017-11-02 12:41:06,902 ERROR  MySQL|dev_db1|binlog  Error parsing DDL statement and updating tables: create table xxxxxxxx_definition(
      yyyyyyyyy int(11),
      order_num int(11),
      definition_type text(20)
      )   [io.debezium.connector.mysql.MySqlSchema]
      2017-11-02 12:41:06,906 ERROR  MySQL|dev_db1|binlog  Failed due to error: Error processing binlog event   [io.debezium.connector.mysql.BinlogReader]
      org.apache.kafka.connect.errors.ConnectException: Expecting ')' at line 4, column 21 but found '(': definition_type text ===>> (20)
      )
              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:336)
              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 ')' at line 4, column 21 but found '(': definition_type text ===>> (20)
      )
              at io.debezium.text.TokenStream.consume(TokenStream.java:706)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:563)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:378)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:281)
              at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:152)
              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:469)
              at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:323)
              ... 5 more
      2017-11-02 12:41:06,912 INFO   MySQL|dev_db1|binlog  Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored.   [io.debezium.connector.mysql.BinlogReader]
      2017-11-02 12:41:07,192 ERROR  ||  Task inventory-connector-0 threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
      

            jpechane Jiri Pechanec
            jaggaer-afoxson Adam Foxson (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: