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

Handling of PRECISION in ddl statements

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Critical
    • None
    • 0.6.2
    • mysql-connector
    • None
    • Hide

      Setting "database.history.skip.unparseable.ddl": "true" can help you move forward.

      Show
      Setting "database.history.skip.unparseable.ddl": "true" can help you move forward.
    • Hide

      Not sure but having a double column created by Spring Boot JPA, causes this, cant share the exact DDL statement. Will update the relevant columns soon.

      Show
      Not sure but having a double column created by Spring Boot JPA, causes this, cant share the exact DDL statement. Will update the relevant columns soon.

    Description

      Getting following status :

      [{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingE exception: Expecting ')' at line 1, column 236 but found 'PRECISION': , DOUBLE_VAL DOUBLE  ===>> PRECISION , IDENTIFY
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192)
      	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:157)
      	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
      	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
      	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:1149)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      	at java.lang.Thread.run(Thread.java:748)
      Caused by: io.debezium.text.ParsingException: Expecting ')' at line 1, column 236 but found 'PRECISION': , DOUBLE_VAL DOUBLE  ===>> PRECISION , IDENTIFY
      	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.relational.history.AbstractDatabaseHistory.lambda$recover$0(AbstractDatabaseHistory.java:61)
      	at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:212)
      	at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:55)
      	at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:315)
      	at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:116)
      	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:80)
      \t... 8 more
      ","id":0,"worker_id":"10.56.11.34:8083"}],"type":"source"}
      

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            usopan Utkarsh Sopan (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: