flink-cdc

flink-cdc copied to clipboard

[FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector.

1

qg-lin

[FLINK-35090][cdc][doris] Add database auto-creating support for Doris sink pipeline connector

3

Currently, Doris sink supports auto-creating table only. When specified database does not exist, connector will panic with a Doris internal error. By ensuring database exists before creating any table should...

yuxiqian

[FLINK-35436]Fixed Schema Behavior Action for the Pipeline.

4

Jiar: https://issues.apache.org/jira/browse/FLINK-35436

hk-lrzy

This PR: * Adds guide to provide excluded DB drivers in quickstart docs * Updates outdated maven jar links & move to `org.apache.flink` group ID

yuxiqian

[FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0

6

fix [FLINK-35391](https://issues.apache.org/jira/browse/FLINK-35391)

beryllw

Flink cdc ci `compile_and_test` miss pipeline connector paimon. And test ci https://github.com/beryllw/flink-cdc/actions/runs/9183968055

beryllw

Flink CDC 3.1 adds two new pipeline connectors (Kafka & Paimon). Added them into auto-labeler to tag PRs more precisely.

yuxiqian

[FLINK-34908][pipeline-connector][doris] Fix Mysql pipeline to doris will lost precision for timestamp

5

[FLINK-34908](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-34908) * I support time precision for doris * I add UTCase

gong

[FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table

2

[cdc-connector][oracle] Oracle cdc support newly add table [FLINK-34990](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-34990) * I add oracle cdc support newly add table * I add ITCase for this feature

gong

[FLINK-35441][tests] Add migration test cases

1

This closes FLINK-35441. Adding backwards compatible test with `3.0.0` and `3.1.0` version by serializing objects on lower versions and deserializing them on snapshot version. * `SchemaManager` test runs on `3.1.0`...

yuxiqian