flink-cdc

flink-cdc copied to clipboard

Implement comma-separated parsing for chunk key columns

4

This PR adds support for per-table chunk key column configuration in the PostgreSQL CDC connector, enabling fine-grained control over incremental snapshot chunking. Previously, all tables shared the same chunk key...

xxntti3n

This closes https://issues.apache.org/jira/browse/FLINK-38110 When there's column name in Chinese in PG tables, Postgresql connector with pgoutput plugin will decode them as garbled characters, especially during incremental capure. The reason is...

qingfei1994

[FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image

2

## What is the purpose of the change This PR resolves the issue where OceanBase CDC integration tests were disabled in GitHub CI due to the unavailability of OceanBase Binlog...

yuanoOo

[FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when…

1

invalidateTable when receiving SchemaChangeEvent to prevent retrieving outdated schema

tbpure

The Flink CDC type supports the timeTZ field type. Like postgres sql supported timeTZ.

Mrart

issues: https://issues.apache.org/jira/browse/FLINK-38249 # Describe In some scenarios, users may want to filter out certain delete operations. This configuration allows Debezium to filter these operations, helping meet user requirements while reducing...

danzhewuju