Yanquan Lv created FLINK-38186:
----------------------------------
Summary: Failed case:
NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog
Key: FLINK-38186
URL: https://issues.apache.org/jira/browse/FLINK-38186
Project: Flink
Issue Type: Sub-task
Components: Flink CDC
Affects Versions: cdc-3.4.0
Reporter: Yanquan Lv
Link:
[https://github.com/apache/flink-cdc/actions/runs/16699557741/job/47268465491]
Error message:
{code:java}
51184 [debezium-reader-0] ERROR
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter - Find schema
need to change dateType, but failed. Field name:test_time, field type:TIME,
field value:PT1M10S, field default value:null
51184 [debezium-reader-0] ERROR io.debezium.relational.TableSchemaBuilder -
Failed to properly convert data value for
'date_convert_test_kd4gij.date_convert_test.test_time' of type TIME for row [4,
2024-06-12T15:04:00.000+0300, null, null, PT1M10S]:
java.lang.RuntimeException: MysqlDebeziumConverter error
at
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter.lambda$registerDateConverter$1(MysqlDebeziumTimeConverter.java:124)
~[classes/:?]
at
io.debezium.relational.CustomConverterRegistry.lambda$getValueConverter$0(CustomConverterRegistry.java:150)
~[debezium-core-1.9.8.Final.jar:3.5-SNAPSHOT]
at
io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$5(TableSchemaBuilder.java:297)
~[debezium-core-1.9.8.Final.jar:3.5-SNAPSHOT]
at
io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:141)
~[debezium-core-1.9.8.Final.jar:3.5-SNAPSHOT]
at
io.debezium.relational.RelationalChangeRecordEmitter.emitReadRecord(RelationalChangeRecordEmitter.java:111)
~[flink-connector-debezium-3.5-SNAPSHOT.jar:3.5-SNAPSHOT]
at
io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:57)
~[flink-connector-debezium-3.5-SNAPSHOT.jar:3.5-SNAPSHOT]
at
io.debezium.pipeline.EventDispatcher.dispatchSnapshotEvent(EventDispatcher.java:155)
~[debezium-core-1.9.8.Final.jar:1.9.8.Final]
at
org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.createDataEventsForTable(MySqlSnapshotSplitReadTask.java:292)
~[classes/:?]
at
org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.createDataEvents(MySqlSnapshotSplitReadTask.java:230)
~[classes/:?]
at
org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.doExecute(MySqlSnapshotSplitReadTask.java:171)
~[classes/:?]
at
org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask.execute(MySqlSnapshotSplitReadTask.java:129)
~[classes/:?]
at
org.apache.flink.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.snapshot(SnapshotSplitReader.java:176)
~[classes/:?]
at
org.apache.flink.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.lambda$submitSplit$1(SnapshotSplitReader.java:161)
~[classes/:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.time.temporal.UnsupportedTemporalTypeException: Unsupported
field: YearOfEra
at java.time.LocalTime.get0(LocalTime.java:701) ~[?:?]
at java.time.LocalTime.getLong(LocalTime.java:678) ~[?:?]
at
java.time.format.DateTimePrintContext.getValue(DateTimePrintContext.java:308)
~[?:?]
at
java.time.format.DateTimeFormatterBuilder$NumberPrinterParser.format(DateTimeFormatterBuilder.java:2702)
~[?:?]
at
java.time.format.DateTimeFormatterBuilder$CompositePrinterParser.format(DateTimeFormatterBuilder.java:2341)
~[?:?]
at
java.time.format.DateTimeFormatter.formatTo(DateTimeFormatter.java:1843) ~[?:?]
at
java.time.format.DateTimeFormatter.format(DateTimeFormatter.java:1817) ~[?:?]
at java.time.LocalTime.format(LocalTime.java:1435) ~[?:?]
at
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter.formatTime(MysqlDebeziumTimeConverter.java:284)
~[classes/:?]
at
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter.convertToTime(MysqlDebeziumTimeConverter.java:258)
~[classes/:?]
at
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter.convertDateObject(MysqlDebeziumTimeConverter.java:160)
~[classes/:?]
at
io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter.lambda$registerDateConverter$1(MysqlDebeziumTimeConverter.java:121)
~[classes/:?]
... 15 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
