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

Failed to parse the sql statement of RENAME user

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 0.7.0
    • 0.6
    • mysql-connector
    • None

    Description

      org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: 
      Expecting token type 128 at line 1, column 8 but found 'USER': RENAME  ===>> USER 'wujin'@'211.10
      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)\nCaused by: io.debezium.text.ParsingException: 
      Expecting token type 128 at line 1, column 8 but found 'USER': RENAME  ===>> USER 'wujin'@'211.10
      at io.debezium.text.TokenStream.consume(TokenStream.java:737)
      at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568)
      at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376)
      at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:168)
      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)
      ... 8 more\n
      

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            wenxzhen Wenxing Zheng (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: