Skip to content

Pull requests: apache/flink-cdc

New pull request New
64 Open 2,017 Closed
64 Open 2,017 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-38139] Fix consecutive online schema change causes job failure. approved mysql-cdc-connector mysql-pipeline-connector reviewed
#4324 opened Mar 19, 2026 by beryllw Loading…
8
[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…
[FLINK-38729] Add Flink2 support for Source/Pipeline connector. base build common composer connector-test-util db2-cdc-connector debezium dist doris-pipeline-connector e2e-tests elasticsearch-pipeline-connector iceberg-pipeline-connector kafka-pipeline-connector maxcompute-pipeline-connector mongodb-cdc-connector mysql-cdc-connector mysql-pipeline-connector oceanbase-cdc-connector oceanbase-pipeline-connector oracle-cdc-connector paimon-pipeline-connector postgres-cdc-connector postgres-pipeline-connector sqlserver-cdc-connector starrocks-pipeline-connector tidb-cdc-connector values-pipeline-connector vitess-cdc-connector
#4322 opened Mar 18, 2026 by lvyanquan Loading…
1 task done
18
[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-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. base build postgres-cdc-connector postgres-pipeline-connector
#4316 opened Mar 16, 2026 by loserwang1024 Loading…
20
[FLINK-39245][Iceberg] Add AWS Glue Catalog support for Iceberg pipeline connector docs Improvements or additions to documentation iceberg-pipeline-connector
#4314 opened Mar 12, 2026 by norrishuang Loading…
13
[FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader mysql-cdc-connector
#4311 opened Mar 10, 2026 by chengcongchina 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…
8
[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 runtime
#4299 opened Mar 4, 2026 by VinaySagarGonabavi Loading…
1
[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 base mysql-cdc-connector
#4296 opened Mar 3, 2026 by ChengbingLiu Loading…
2
[FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type
#4295 opened Mar 3, 2026 by zml1206 Loading…
3
[FLINK-39171][oracle-cdc] Fix Oracle pipeline connector wrong field case e2e-tests
#4292 opened Feb 28, 2026 by Hisoka-X Loading…
2
[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-37837][core] Always add create.table to include.schema.changes option cli docs Improvements or additions to documentation
#4262 opened Feb 5, 2026 by Hisoka-X Loading…
7
[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…
19
[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…
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.