flink-cdc

flink-cdc copied to clipboard

[cdc-connector][oracle]Flink cdc pipeline support oracle source

6

Flink cdc pipeline support oracle source   

ChengJie1053

OracleSchema getTableSchema Description Changed from `mysql` to`oracle`

ChengJie1053

[FLINK-35654][docs] Add CDC release verification & Installation guide

2

This closes FLINK-35654. Currently, ASF voting process requires vast quality verification before releasing any new versions, including: * Tarball checksum verification * Compile from source code * Run pipeline E2e...

yuxiqian

whhe

[FLINK-35718][mysql] cherry pick DBZ-5333 from debezium MySqlErrorHandler and add logs.

2

copy from https://github.com/debezium/debezium/blob/1.9/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlErrorHandler.java.

lvyanquan

[FLINK-35713][cdc-compose] Add sink PARALLELISM for flink-cdc.

3

proletarians

[FLINK-35467][cdc-dist][bin] Respect externally set FLINK_CONF_DIR for CDC task configuration.

2

Refer to: https://issues.apache.org/jira/browse/FLINK-35467 Respect externally set FLINK_CONF_DIR for CDC task configuration The script has been modified to check if the FLINK_CONF_DIR environment variable is set externally before defaulting to $FLINK_HOME/conf....

joyCurry30

Handle map and array types binary record data

5

umeshdangat

[FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file

5

ThorneANN

  

ChengJie1053