Skip to content

Pull requests: apache/flink-cdc

New pull request New
105 Open 2,194 Closed
105 Open 2,194 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

[hotfix][runtime Preserve original failure during distributed schema evolution composer runtime
#4556 opened Sep 22, 2026 by yuxiqian Member Loading…
1 task done
[FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery
#4555 opened Sep 22, 2026 by fxbing Contributor Loading…
1 task done
[FLINK-40679][pipeline-connector/iceberg] Support Iceberg table maintenance common composer docs Improvements or additions to documentation e2e-tests iceberg-pipeline-connector mysql-pipeline-connector postgres-pipeline-connector
#4544 opened Sep 16, 2026 by zml1206 Contributor Loading…
1 task done
@lvyanquan
2
[FLINK-40650][cdc-connector][sqlserver] Improve SqlServerDialect.discoverDataCollectionSchemas to reduce snapshot start time with many tables sqlserver-cdc-connector
#4543 opened Sep 15, 2026 by stefanofrancoscania Loading…
1 task done
[hotfix][cdc-composer] Fix "URI is not hierarchical" when resolving factory JAR path composer
#4542 opened Sep 15, 2026 by wangmingzhou1986 Loading…
[FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation approved cli common composer docs Improvements or additions to documentation e2e-tests paimon-pipeline-connector reviewed runtime
#4540 opened Sep 14, 2026 by haruki-830 Contributor Loading…
23
[FLINK-40646][Postgres] Pooled JDBC connections use the default application name. postgres-cdc-connector
#4538 opened Sep 14, 2026 by loserwang1024 Contributor Loading…
1 task
1
[FLINK-40508][pipeline-connector/db2] Support DB2 pipeline connector build docs Improvements or additions to documentation
#4533 opened Sep 12, 2026 by suntectec Contributor Loading…
1 task done
[FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime common composer e2e-tests postgres-pipeline-connector runtime
#4530 opened Sep 8, 2026 by tchivs Contributor Loading…
1 task done
14
[FLINK-40532][docs] Remove experimental warning from scan.parse.online.schema.changes.enabled docs Improvements or additions to documentation reviewed
#4529 opened Sep 8, 2026 by Admaing Loading…
1 task
[FLINK-40575][pipeline-connector/fluss] Support dynamic table unsubscription and re-subscription common docs Improvements or additions to documentation
#4527 opened Sep 7, 2026 by fxbing Contributor Loading…
1 task done
1
[FLINK-40552][runtime] Support asynchronous transform execution add-ons common composer docs Improvements or additions to documentation e2e-tests runtime
#4526 opened Sep 7, 2026 by haruki-830 Contributor Loading…
1 task done
13
[FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes postgres-cdc-connector
#4523 opened Sep 5, 2026 by tchivs Contributor Loading…
1 task done
[FLINK-40538][postgres] Skip WAL position search on idle publication … postgres-cdc-connector
#4521 opened Sep 2, 2026 by eskabetxe Member Loading…
[FLINK-35104] [pipeline-connector/kafka]support pipeline kafka source build common composer docs Improvements or additions to documentation e2e-tests kafka-pipeline-connector paimon-pipeline-connector runtime starrocks-pipeline-connector
#4518 opened Aug 31, 2026 by MOBIN-F Contributor • Draft
1
[FLINK-36605] Bump debezium to last 2.x version base build db2-cdc-connector debezium e2e-tests mysql-cdc-connector mysql-pipeline-connector oceanbase-cdc-connector oracle-cdc-connector postgres-cdc-connector postgres-pipeline-connector sqlserver-cdc-connector vitess-cdc-connector
#4516 opened Aug 28, 2026 by eskabetxe Member Loading…
1 task done
2
[oracle] Support specific-offset startup mode with SCN for Oracle pipeline source
#4510 opened Aug 18, 2026 by fightBoxing Loading…
[FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader docs Improvements or additions to documentation mysql-cdc-connector mysql-pipeline-connector
#4509 opened Aug 17, 2026 by hadoopkandy Loading…
2 tasks done
11
[FLINK-40432][connect/tidb] Split key ranges by TiKV region via FLIP-27 enumerator docs Improvements or additions to documentation tidb-cdc-connector
#4508 opened Aug 17, 2026 by lifulong Loading…
1 task done
2
[FLINK-40385][postgre]Optimize efficiency issues of PostgreSQL during the full snapshot phase. postgres-cdc-connector
#4506 opened Aug 12, 2026 by hql0312 Contributor Loading…
1
[mysql] Preserve schema for no-op CREATE TABLE IF NOT EXISTS ... LIKE mysql-pipeline-connector
#4502 opened Aug 7, 2026 by lelovelo • Draft
[FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source
#4497 opened Aug 4, 2026 by leosanqing Loading…
1 task done
1
[hotfix][postgres] generateCreateTableEvent result is skipped postgres-pipeline-connector
#4490 opened Jul 24, 2026 by CatOrLeader Contributor Loading…
1 task
1
[FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent base
#4489 opened Jul 24, 2026 by dev-donghwan Loading…
[cdc-connector][oracle] Support row_id metadata column and fix headers loss in JdbcSourceFetchTaskContext base oracle-cdc-connector
#4487 opened Jul 24, 2026 by fightBoxing Loading…
ProTip! Add no:assignee to see everything that’s not assigned.