Skip to content

Pull requests: apache/flink-cdc

New pull request New
55 Open 2,053 Closed
55 Open 2,053 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-39342][Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties 3.7 docs Improvements or additions to documentation iceberg-pipeline-connector
#4351 opened Mar 27, 2026 by eric666666 Loading…
[hotfix] Optimize SchemaChangeEventVisitor to reduce class inflations common doris-pipeline-connector paimon-pipeline-connector runtime starrocks-pipeline-connector
#4350 opened Mar 27, 2026 by yuxiqian Loading…
4
[FLINK-39336] Clean up code in the flink-cdc-pipeline-connector-kafka module that is compatible with older versions of Flink approved kafka-pipeline-connector reviewed
#4347 opened Mar 26, 2026 by sd4324530 Loading…
1
[FLINK-39321][pipeline-connector-paimon]Fixes a bug where Flink CDC fails to write to Paimon dynamic bucket tables when dynamic-bucket.initial-buckets=1 and Flink parallelism > 1. paimon-pipeline-connector
#4344 opened Mar 26, 2026 by zhaoruifeng01 Loading…
add dws sink pipeline connector
#4341 opened Mar 26, 2026 by Daishuyuan Loading…
1
[FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill mysql-cdc-connector
#4334 opened Mar 24, 2026 by chengcongchina Loading…
7
[FLINK-39265][postgres] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering postgres-cdc-connector
#4323 opened Mar 18, 2026 by JNSimba Loading…
1
[ci][hotfix] Enable parallel execution for pipeline-e2e tests e2e-tests
#4321 opened Mar 17, 2026 by yuxiqian • Draft
[FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector sqlserver-cdc-connector
#4320 opened Mar 17, 2026 by Daishuyuan Loading…
5
[FLINK-39228][starrocks] Escape quoted default/comment literals in DDL starrocks-pipeline-connector
#4308 opened Mar 9, 2026 by zml1206 Loading…
1
[FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. mysql-cdc-connector
#4302 opened Mar 5, 2026 by chengcongchina Loading…
11
[FLINK-39213][paimon] Filter out empty CommitMessageImpl to avoid unnecessary commit operations. paimon-pipeline-connector
#4301 opened Mar 5, 2026 by lvyanquan Loading…
[FLINK-38828][cdc-common][cdc-runtime] Handle schema evolution upon projection updates via SchemaCoordinator common e2e-tests runtime
#4299 opened Mar 4, 2026 by VinaySagarGonabavi Loading…
2
[FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. mysql-cdc-connector
#4297 opened Mar 3, 2026 by danzhewuju Loading…
[FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end approved base mysql-cdc-connector reviewed
#4296 opened Mar 3, 2026 by ChengbingLiu Loading…
4
[FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type
#4295 opened Mar 3, 2026 by zml1206 Loading…
3
[FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing mysql-cdc-connector
#4291 opened Feb 28, 2026 by e-mhui Loading…
[FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes common composer runtime
#4279 opened Feb 23, 2026 by VinaySagarGonabavi Loading…
15
[FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector
#4267 opened Feb 9, 2026 by Hisoka-X Loading…
2
[FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) doris-pipeline-connector
#4257 opened Feb 3, 2026 by linjianchang Loading…
2
The microseconds default value of '0000-00-00 00:00:00.000000' for MySQL TIMESTAMP fields is not supported in downstream systems. doris-pipeline-connector paimon-pipeline-connector starrocks-pipeline-connector
#4251 opened Jan 31, 2026 by yunhaoww Loading…
1
[Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled docs Improvements or additions to documentation mysql-cdc-connector
#4246 opened Jan 30, 2026 by ThorneANN Loading…
18
[FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector postgres-cdc-connector postgres-pipeline-connector
#4233 opened Jan 22, 2026 by linjianchang Loading… V3.6.0
@lvyanquan
34
[FLINK-38934][cdc connector mysql] honour ssl protocol setting configured in debeziumProps docs Improvements or additions to documentation mysql-cdc-connector oceanbase-cdc-connector
#4225 opened Jan 16, 2026 by watsonjo737 Loading…
[FLINK-38907][postgres] Debezium publication filtering data lost postgres-cdc-connector
#4223 opened Jan 13, 2026 by bakjos Loading…
3
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.