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

Support for TABLE_TYPE missing form MySQL grammar

XMLWordPrintable

    • False
    • False
    • Undefined
    • Hide

      I think this could be reproduced if you point a DBZ MySql 1.5 connector against a database where there's an DDL statement which includes ` table_type=odbc `. Though I have not reproduced it myself. 

       

      Show
      I think this could be reproduced if you point a DBZ MySql 1.5 connector against a database where there's an DDL statement which includes ` table_type=odbc `. Though I have not reproduced it myself.   

       

      Hi there,

      I am running into the following error on DBZ Mysql CDC source 1.5, where the connector is unable to parse the following DDL statement. I think the point where it errors is "table_type=odbc". The logs in the connector suggested opening up a DBZ ticket for this.  

      io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table A(
        ) engine = connect table_type=odbc 
        xxxxx
'
mismatched input 'table_type' expecting {<EOF>, '--'}
	at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
	at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
	at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139)
	at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:905)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
	at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80)
	at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:210)
	at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:197)
	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:574)
	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:352)

       

       

              anmohant Anisha Mohanty
              sajanaw97 Saj Weerawardhena (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: