flink-cdc issues

[FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink

4

dingxin-tech

docs

build

e2e-tests

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

4

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...

wangxiaojing

[oracle] The STRUCT type processing exception

3

wangxiaojing

[#1770] fix NumberFormatException when mysql server_id is larger than INT_MAX

3

this close issue https://github.com/ververica/flink-cdc-connectors/issues/1770

legendtkl

[tidb-cdc]When the task runs for a period of time, there are only Resolved Events

3

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...

wangxiaojing

Switch to a MySQL image with arm64 support

1

Closes #1367 [The official MySQL distribution](https://www.mysql.com/de/support/supportedplatforms/database.html) doesn't support arm64 architecture for 5.7, so it's not possible to run tests on an Apple Silicon machine natively. https://github.com/biarms/mysql is a distribution that's...

sap1ens

[mysql][oracle] Quote primary key when split snapshot

8

MySqlSnapshotSplitReadTask throw exception when primary key conflict with keywords or reserved words. sample table: ``` CREATE TABLE quote_pk_table ( `key` VARCHAR(10) NOT NULL PRIMARY KEY, name VARCHAR(255) NOT NULL DEFAULT...

huhuan1898

mysql-cdc-connector

base

postgres-cdc-connector

sqlserver-cdc-connector

db2-cdc-connector

Stale

升级Jackson版本

6

cdc中使用的[debezium](https://github.com/debezium/debezium)版本为1.6.4.Final，其依赖的Jackson-core版本为2.10.5,[jackson-databind](https://github.com/FasterXML/jackson-databind)版本为2.10.5.1。 flink自从1.13之后使用的Jackson版本为2.13.2。 Jackson的[com.fasterxml.jackson.databind.cfg.MapperConfig.java](https://github.com/FasterXML/jackson-databind/blob/2.14/src/main/java/com/fasterxml/jackson/databind/cfg/MapperConfig.java)中属性_mapperFeatures类型在2.13版本之前为int，在2.13版本开始变更为long。从而导致了使用sql-cdc会出现Caused by: java.io.InvalidClassException: com.ververica.cdc.connectors.shaded.com.fasterxml.jackson.databind.cfg.MapperConfig; incompatible types for field _mapperFeatures错误。

Desperado2