flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[oracle]Error when TIMESTAMP_LTZ type is encoded in string type

Open wangxiaojing opened this issue 3 years ago • 4 comments

2022-12-06 00:30:55 java.time.format.DateTimeParseException: Text '2022-12-06T00:30:52+08:00' could not be parsed at index 19 at java.base/java.time.format.DateTimeFormatter.parseResolved0(Unknown Source) at java.base/java.time.format.DateTimeFormatter.parse(Unknown Source) at java.base/java.time.Instant.parse(Unknown Source) at com.ververica.cdc.connectors.oracle.table.OracleDeserializationConverterFactory$4.convert(OracleDeserializationConverterFactory.java:165) at com.ververica.cdc.connectors.oracle.table.OracleDeserializationConverterFactory$5.convert(OracleDeserializationConverterFactory.java:193) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema$17.convert(RowDataDebeziumDeserializeSchema.java:641) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.convertField(RowDataDebeziumDeserializeSchema.java:626) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.access$000(RowDataDebeziumDeserializeSchema.java:63) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema$16.convert(RowDataDebeziumDeserializeSchema.java:611) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema$17.convert(RowDataDebeziumDeserializeSchema.java:641) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.extractAfterRow(RowDataDebeziumDeserializeSchema.java:146) at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.deserialize(RowDataDebeziumDeserializeSchema.java:121) at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.handleBatch(DebeziumChangeFetcher.java:229) at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.runFetchLoop(DebeziumChangeFetcher.java:151) at com.ververica.cdc.debezium.DebeziumSourceFunction.run(DebeziumSourceFunction.java:446) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)

wangxiaojing avatar Dec 06 '22 10:12 wangxiaojing

The Error in test_ci_build tidb and test_ci_build e2e ,but i did not update this module

wangxiaojing avatar Dec 06 '22 11:12 wangxiaojing

Thanks @wangxiaojing for the great work, could you please rebase this PR with latest master branch?

yuxiqian avatar Apr 25 '24 08:04 yuxiqian

This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs.

github-actions[bot] avatar Jul 17 '24 00:07 github-actions[bot]