Skip to content

Pull requests: apache/flink-cdc

New pull request New
114 Open 2,166 Closed
114 Open 2,166 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-40640][iceberg] Fix duplicate rows when an UPDATE changes the partition value iceberg-pipeline-connector
#4536 opened Sep 13, 2026 by dataengineervishal Loading…
[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
[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
[hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY mysql-cdc-connector
#4532 opened Sep 11, 2026 by yuxiqian Member Loading…
1 task done
[hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events common runtime
#4531 opened Sep 11, 2026 by yuxiqian Member 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 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 Loading…
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
[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…
[oracle] Support row_id metadata column for Oracle CDC (with headers-loss bug fix)
#4486 opened Jul 24, 2026 by fightBoxing Loading…
[FLINK-40203][runtime] Add an explicit option for Flink SQL-compatible YAML Transform expression semantics cli common composer docs Improvements or additions to documentation runtime
#4484 opened Jul 23, 2026 by haruki-830 Contributor Loading…
7
ProTip! no:milestone will show everything without a milestone.