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

A column named `column`, even when properly escaped, causes exception

XMLWordPrintable

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

      Kafka Connect log:

      2017-10-17 13:20:51,306 ERROR  MySQL|db1|binlog  Error parsing DDL statement and updating tables: CREATE TABLE `abc` (
        `def` int(11) unsigned NOT NULL AUTO_INCREMENT,
        `ghi` int(11) NOT NULL DEFAULT '0',
        `jkl` tinyint(4) unsigned NOT NULL,
        `mno` varchar(255) NOT NULL DEFAULT '',
        `pqr` int(11) NOT NULL DEFAULT '0',
        `column` varchar(255) NOT NULL DEFAULT '',
        PRIMARY KEY (`def`),
        KEY `stu` (`jkl`,`ghi`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8   [io.debezium.connector.mysql.MySqlSchema]
      io.debezium.text.ParsingException: Expecting ')' at line 7, column 20 but found '255':
        `column` varchar( ===>> 255) NOT NULL DEFAUL
              at io.debezium.text.TokenStream.consume(TokenStream.java:706)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:559)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:376)
              at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:279)
              at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:150)
              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:351)
              at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461)
              at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
              at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
              at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
              at java.lang.Thread.run(Thread.java:748)
      

              gunnar.morling Gunnar Morling
              jaggaer-afoxson Adam Foxson (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: