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

java.time.format.DateTimeParseException: java.time.format.DateTimeParseException

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • 0.10.0.CR2
    • 0.10.0.Beta4
    • mysql-connector
    • None

      Hi,
      we have on all our connector the following:

      {
        "name": "zcs-qas-01",
        "connector": {
          "state": "RUNNING",
          "worker_id": "hrxkfqdc01.hrx.erp:8083"
        },
        "tasks": [
          {
            "id": 0,
            "state": "FAILED",
            "worker_id": "hrxkfqdc01.hrx.erp:8083",
            "trace": "org.apache.kafka.connect.errors.ConnectException: java.time.format.DateTimeParseException: Text '9999-12-31' could not be parsed at index 10\n\tat io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:275)\n\tat io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:49)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:199)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.time.format.DateTimeParseException: Text '9999-12-31' could not be parsed at index 10\n\tat java.time.format.DateTimeFormatter.parseResolved0(DateTimeFormatter.java:1949)\n\tat java.time.format.DateTimeFormatter.parse(DateTimeFormatter.java:1777)\n\tat io.debezium.connector.mysql.MySqlDefaultValueConverter.convertToLocalDateTime(MySqlDefaultValueConverter.java:141)\n\tat io.debezium.connector.mysql.MySqlDefaultValueConverter.convert(MySqlDefaultValueConverter.java:80)\n\tat io.debezium.connector.mysql.MySqlDefaultValueConverter.setColumnDefaultValue(MySqlDefaultValueConverter.java:273)\n\tat io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.convertDefaultValueToSchemaType(ColumnDefinitionParserListener.java:306)\n\tat io.debezium.connector.mysql.antlr.listener.ColumnDefinitionParserListener.enterDefaultValue(ColumnDefinitionParserListener.java:155)\n\tat io.debezium.ddl.parser.mysql.generated.MySqlParser$DefaultValueContext.enterRule(MySqlParser.java:47353)\n\tat io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46)\n\tat io.debezium.connector.mysql.antlr.listener.MySqlAntlrDdlParserListener.enterEveryRule(MySqlAntlrDdlParserListener.java:89)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28)\n\tat io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:85)\n\tat io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:105)\n\tat io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:247)\n\tat io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:74)\n\tat io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:250)\n\tat io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:164)\n\tat io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:105)\n\t... 9 more\n"
          }
        ],
        "type": "source"
      }
      

      Kafka logs show:
      .........

      ../logs/confluent-kafka-connect/connect-worker.log.2019-09-23-10:Caused by: java.time.format.DateTimeParseException: Text '9999-12-31' could not be parsed at index 10
      ../logs/confluent-kafka-connect/connect-worker.log.2019-09-24-10:  "ddl" : "ALTER TABLE `employments` ADD `valid_to` datetime DEFAULT '9999-12-31'"
      ../logs/confluent-kafka-connect/connect-worker.log.2019-09-24-10:java.time.format.DateTimeParseException: Text '9999-12-31' could not be parsed at index 10
      ../logs/confluent-kafka-connect/connect-worker.log.2019-09-24-10:org.apache.kafka.connect.errors.ConnectException: java.time.format.DateTimeParseException: Text '9999-12-31' could not be parsed at index 10
      

      what is the issue ?
      how can it be solved ?

      regards,
      Eric

              jpechane Jiri Pechanec
              eric.franckx@ngahr.com Eric FRANCKX (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: