[
https://issues.apache.org/jira/browse/FLINK-37369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37369:
-------------------------------
Description:
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)
!image-2025-02-21-17-57-50-198.png!
was:
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)
> 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
> Priority: Major
> Attachments: image-2025-02-21-17-57-50-198.png
>
>
> 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)
>
> !image-2025-02-21-17-57-50-198.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
