flink-cdc

flink-cdc copied to clipboard

[FLINK-35242] Supports per-SE type configuration & tolerance evolution behavior

2

This closes FLINK-35242. * Adds `TRY_EVOLVE` behavior that tolerates exception during metadata applying process * Supports configuring various behavior for each schema evolution type with `include.schema.changes` and `exclude.schema.changes` sink option...

yuxiqian

[FLINK-35432]Support catch modify event for the mysql.

3

Doris & StarRocks are not support the `UpdateTypeEvent` right now, So should i need change the implement for Doris and Starrocks to ignore the UpdateTypeEvent to keep job healthy?

hk-lrzy

This closes [FLINK-34877](https://issues.apache.org/jira/browse/FLINK-34877).

aiwenmo

[FLINK-35447][doc-ci] Flink CDC Document document file had removed but website can access

2

Solution: Deletes files from the destination directory that are not present in the source directory.

GOODBOY008

[FLINK-35415][base] Fix compatibility with Flink 1.19

3

This closes FLINK-35316, FLINK-35415. * Adds E2e testcases on recent Flink versions including 1.19 * Fixes CDC compatibility issue with 1.19 (due to breaking changes in @Internal classes) This is...

yuxiqian

[FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method

1

The issue is described in [FLINK-35409](https://issues.apache.org/jira/browse/FLINK-35409).

Shawn-Hx

Now, MySQL CDC connector will retrieve the offset seconds between the configured timezone and UTC by executing the SQL statement below, and then compare it with the configured timezone. ```SQL...

Shawn-Hx

[FLINK-35421]fixed schema operator blocking when restart

2

https://issues.apache.org/jira/browse/FLINK-35421 1. i move refresh action to the `setup` method and remove checker of whether it restored from checkpoint or not. 2. i add some testing for it to double...

hk-lrzy

[FLINK-34545][cdc-pipeline-connector]Add OceanBase pipeline connector to Flink CDC

8

This closes [FLINK-34545](https://issues.apache.org/jira/browse/FLINK-34545).

yuanoOo

Refer to [FLINK-35430](https://issues.apache.org/jira/browse/FLINK-35430) Passed the zoneId to JsonSerializationSchema.

joyCurry30