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

Cannot parse default value 0.000000000000000000 for bigint column

XMLWordPrintable

    • False
    • None
    • False

      Mysql connector parse the decimal default value for bigint column error.

      CREATE TABLE `tbl_default` (  
      `id` int(11) NOT NULL AUTO_INCREMENT,
      c0 tinyint not null default '10.01',
      c1 int not null default '5.234',
      c2 bigint not null default 0.000000000000000000,
      c3 bigint not null default '.12345', 
      c4 smallint not null default 100.12345, 
      PRIMARY KEY (`id`)
      )
      
       
      org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\n\t
      at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)\n\t
      at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369)\n\t
      at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1118)\n\t
      at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:966)\n\t
      at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:606)\n\t
      at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:850)\n\t
      at java.base/java.lang.Thread.run(Thread.java:830)\n
      Caused by: io.debezium.DebeziumException: Error processing binlog event\n\t... 6 more\n
      Caused by: java.lang.NumberFormatException: For input string: \"0.000000000000000000\"\n\t
      at java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:68)\n\t
      at java.base/java.lang.Long.parseLong(Long.java:699)\n\tat java.base/java.lang.Long.valueOf(Long.java:1151)\n\t
      at io.debezium.jdbc.JdbcValueConverters.lambda$convertBigInt$42(JdbcValueConverters.java:919)\n\t
      at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1288)\n\t
      at io.debezium.jdbc.JdbcValueConverters.convertBigInt(JdbcValueConverters.java:907)\n\t
      at io.debezium.jdbc.JdbcValueConverters.lambda$converter$6(JdbcValueConverters.java:297)\n\t
      at io.debezium.connector.mysql.MySqlDefaultValueConverter.setColumnDefaultValue(MySqlDefaultValueConverter.java:405)\n\t
      at io.debezium.connector.mysql.antlr.listener.CreateTableParserListener.convertDefaultValueToSchemaType(CreateTableParserListener.java:147)\n\t
      at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)\n\t
      at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)\n\t
      at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1621)\n\t
      at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)\n\t
      at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)\n\t
      at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)\n\t
      at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)\n\t
      at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578)\n\t
      at io.debezium.connector.mysql.antlr.listener.CreateTableParserListener.lambda$exitColumnCreateTable$1(CreateTableParserListener.java:75)
      at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.runIfNotNull(MySqlAntlrDdlParser.java:357)\n\t
      at io.debezium.connector.mysql.antlr.listener.CreateTableParserListener.exitColumnCreateTable(CreateTableParserListener.java:55)\n\t
      at io.debezium.ddl.parser.mysql.generated.MySqlParser$ColumnCreateTableContext.exitRule(MySqlParser.java:4715)\n\t
      at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateExitRule(ProxyParseTreeListenerUtil.java:64)\n\t
      at io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.exitEveryRule(MySqlAntlrDdlParserListener.java:106)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.exitRule(ParseTreeWalker.java:48)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:30)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\t
      at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\t
      at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)\n\t
      at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:210)\n\t
      at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:197)\n\t
      at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:574)\n\t
      at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:352)\n\t
      

            Unassigned Unassigned
            ywyuewei Harvey Yue (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: