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

DDL Parsing Exception for fulltext index

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 0.4.1
    • 0.4
    • mysql-connector
    • None

    Description

      Parsing of the following DDL fails:

      {
        "source" : {
          "server" : "localhost.9092"
        },
        "position" : {
          "file" : "mysql-bin.000001",
          "pos" : 151,
          "snapshot" : true
        },
        "databaseName" : "auth_context_local",
        "ddl" : "CREATE TABLE `roles` (\n  `id` varchar(32) NOT NULL,\n  `name` varchar(100) NOT NULL,\n  `context` varchar(20) NOT NULL,\n  `organization_id` int(11) DEFAULT NULL,\n  `client_id` varchar(32) NOT NULL,\n  `scope_action_ids` text NOT NULL,\n  PRIMARY KEY (`id`),\n  FULLTEXT KEY `scope_action_ids_idx` (`scope_action_ids`)\n) ENGINE=InnoDB DEFAULT CHARSET=utf8"
      }
      

      It generates the following error on debezium startup:

      [2017-02-10 19:37:04,731] ERROR Task cep_debezium_mysql-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142)
      org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: Expecting ')' at line 9, column 16 but found 'scope_action_ids_idx': `),
        FULLTEXT KEY ` ===>> scope_action_ids_idx
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192)
      	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:137)
      	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      	at java.lang.Thread.run(Thread.java:745)
      Caused by: io.debezium.text.ParsingException: Expecting ')' at line 9, column 16 but found 'scope_action_ids_idx': `),
        FULLTEXT KEY ` ===>> scope_action_ids_idx
      	at io.debezium.text.TokenStream.consume(TokenStream.java:694)
      	at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:546)
      	at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:363)
      	at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:266)
      	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:141)
      	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
      	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
      	at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$0(AbstractDatabaseHistory.java:57)
      	at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:202)
      	at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:52)
      	at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:312)
      	at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:116)
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:80)
      	... 8 more
      [2017-02-10 19:37:04,731] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:143)
      

      Attachments

        Activity

          People

            rhauch Randall Hauch (Inactive)
            johan.genberg Johan Genberg (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: