caixiaowei created FLINK-37369:
----------------------------------
Summary: Flink CDC OceanBase Connector Throws Exception for Column
DEFAULT VALUE CURRENT_TIMESTAMP
Key: FLINK-37369
URL: https://issues.apache.org/jira/browse/FLINK-37369
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.1.0
Reporter: caixiaowei
When the table schema contains the following field:
create_time DATETIME(23) NOT NULL DEFAULT VALUE
The following exception is thrown：
Caused by: java.lang.IllegalArgumentException: Timestamp format must be
yyyy-mm-dd hh:mm:ss[.fffffffff]
at java.sql/java.sql.Timestamp.valueOf(Timestamp.java:196)
at
org.apache.flink.cdc.connectors.oceanbase.source.converter.OceanBaseValueConverters.convertTimestamp(OceanBaseValueConverters.java:441)
at
org.apache.flink.cdc.connectors.oceanbase.source.converter.OceanBaseValueConverters.lambda$converter$22(OceanBaseValueConverters.java:301)
at
org.apache.flink.cdc.connectors.oceanbase.source.converter.OceanBaseDefaultValueConverter.parseDefaultValue(OceanBaseDefaultValueConverter.java:62)
at
io.debezium.relational.TableSchemaBuilder.lambda$addField$9(TableSchemaBuilder.java:393)
at java.base/java.util.Optional.flatMap(Optional.java:294)
at
io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:393)
at
io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:149)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:147)
at
io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135)
at
io.debezium.relational.RelationalDatabaseSchema.refreshSchema(RelationalDatabaseSchema.java:209)
at
io.debezium.relational.RelationalDatabaseSchema.refresh(RelationalDatabaseSchema.java:200)
at
org.apache.flink.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction.getTableSchema(OceanBaseRichSourceFunction.java:309)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
