-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Pull requests: apache/flink-cdc
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-39228][starrocks] Escape quoted default/comment literals in DDL
starrocks-pipeline-connector
#4308
opened Mar 9, 2026 by
zml1206
Loading…
feat: Flink 2.2 compatibility and dual-dist packaging
base
build
cli
common
composer
db2-cdc-connector
dist
docs
Improvements or additions to documentation
e2e-tests
elasticsearch-pipeline-connector
iceberg-pipeline-connector
kafka-pipeline-connector
maxcompute-pipeline-connector
mongodb-cdc-connector
mysql-cdc-connector
mysql-pipeline-connector
oracle-cdc-connector
paimon-pipeline-connector
postgres-cdc-connector
postgres-pipeline-connector
runtime
sqlserver-cdc-connector
starrocks-pipeline-connector
tidb-cdc-connector
values-pipeline-connector
#4307
opened Mar 6, 2026 by
macdoor
Loading…
[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…
[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…
[FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type
#4295
opened Mar 3, 2026 by
zml1206
Loading…
[FLINK-38729] Add support for Flink 2.2.0
build
cli
common
composer
dist
e2e-tests
elasticsearch-pipeline-connector
iceberg-pipeline-connector
kafka-pipeline-connector
mysql-pipeline-connector
paimon-pipeline-connector
postgres-pipeline-connector
runtime
starrocks-pipeline-connector
values-pipeline-connector
#4294
opened Mar 2, 2026 by
lvyanquan
Loading…
[FLINK-39071][oracle-cdc] Fix Oracle pipeline connector wrong field case
e2e-tests
#4292
opened Feb 28, 2026 by
Hisoka-X
Loading…
[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-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges
#4286
opened Feb 25, 2026 by
Hisoka-X
Loading…
[FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes
common
runtime
#4279
opened Feb 23, 2026 by
VinaySagarGonabavi
Loading…
[FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector
add-ons
base
build
cli
composer
connector-test-util
db2-cdc-connector
debezium
docs
Improvements or additions to documentation
doris-pipeline-connector
e2e-tests
elasticsearch-pipeline-connector
iceberg-pipeline-connector
kafka-pipeline-connector
mongodb-cdc-connector
mysql-cdc-connector
mysql-pipeline-connector
oceanbase-pipeline-connector
oracle-cdc-connector
paimon-pipeline-connector
postgres-cdc-connector
postgres-pipeline-connector
runtime
sqlserver-cdc-connector
starrocks-pipeline-connector
tidb-cdc-connector
vitess-cdc-connector
[FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector
#4267
opened Feb 9, 2026 by
Hisoka-X
Loading…
[FLINK-37837][core] Always add create.table to include.schema.changes option
cli
#4262
opened Feb 5, 2026 by
Hisoka-X
Loading…
[FLINK-39027][pipeline-connector][postgres] Support DDL for postgres pipeline connector
postgres-cdc-connector
postgres-pipeline-connector
#4259
opened Feb 4, 2026 by
zml1206
Loading…
[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…
[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…
[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…
[FLINK-38881][postgres] Support partition table routing for PostgreSQL CDC
common
docs
Improvements or additions to documentation
e2e-tests
postgres-cdc-connector
postgres-pipeline-connector
#4216
opened Jan 9, 2026 by
tchivs
Loading…
4 tasks done
Previous Next
ProTip!
Find all pull requests that aren't related to any open issues with -linked:issue.