Skip to content

Pull requests: apache/flink-cdc

New pull request New
117 Open 2,176 Closed
117 Open 2,176 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-40697][cdc-base] Release finished snapshot split metadata after entering the stream phase base db2-cdc-connector docs Improvements or additions to documentation oracle-cdc-connector postgres-cdc-connector sqlserver-cdc-connector
#4550 opened Sep 17, 2026 by spoorthibasu Contributor Loading…
1 task
[FLINK-40690][pipeline-connector/fluss] Preserve nested row field positions approved reviewed
#4549 opened Sep 17, 2026 by fxbing Contributor Loading…
1 task done
1
[hotfix][test][sqlserver] Shift test timestamps to avoid Debezium time-type conversion bug sqlserver-cdc-connector
#4548 opened Sep 17, 2026 by yuxiqian Member Loading…
1 task done
[FLINK-40679][pipeline-connector/iceberg] Support Iceberg table maintenance common composer docs Improvements or additions to documentation iceberg-pipeline-connector mysql-pipeline-connector postgres-pipeline-connector
#4544 opened Sep 16, 2026 by zml1206 Contributor Loading…
1 task done
@lvyanquan
[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…
14
[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
[FLINK-40623][cdc-base] Release chunk splitter JDBC connection once a table is split base
#4534 opened Sep 13, 2026 by xucq07 Loading…
1 task done
2
[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
9
[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
[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
9
[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
[FLINK-40473] Fix yarn-application mode failing to locate flink-cdc-dist jar with Flink version suffix composer
#4514 opened Aug 26, 2026 by llphxd Contributor Loading…
[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
1
[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
ProTip! Updated in the last three days: updated:>2026-09-15.