wangxiaojing
wangxiaojing
Oracle type | Flink SQL type -- | -- NUMBER(p, s > 0) s >= 38 or (s < 38 , p + s > 38) | STRING -- |...
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...
Mappings for Oracle numeric data types Oracle Data Type | Literal type (schema type) -- | -- DOUBLE PRECISION | STRUCT -- | -- NUMBER[(P[, *])] | STRUCT -- |...
Environment : Flink version : 1.14.4 Flink CDC version: 2.2 ,2.3 ,master Database and version: tidb5.0 and tidb5.1 To Reproduce flink-tidb-cdc table: A flink-jdbc table: B query: insert into A...
When using partitioned scan in Flink JDBC table, if scan.partition.lower-bound and scan.partition.upper-bound are very large, there could be a situation where one data record is lost. For example, maximum value:...