-
Bug
-
Resolution: Done
-
Blocker
-
0.10.0.Beta4
-
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