-
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-38828][cdc-common][cdc-runtime] Handle schema evolution upon projection updates via SchemaCoordinator
common
runtime
#4299
opened Mar 4, 2026 by
VinaySagarGonabavi
Loading…
[FLINK-38833][paimon] Partitioned fixed-bucket Paimon table write parallelism optimization
paimon-pipeline-connector
#4298
opened Mar 4, 2026 by
sd4324530
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
e2e-tests
runtime
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-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and not have a private instance
#4285
opened Feb 25, 2026 by
ThorneANN
Loading…
[FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes
common
runtime
#4279
opened Feb 23, 2026 by
VinaySagarGonabavi
Loading…
FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING
mysql-cdc-connector
#4278
opened Feb 15, 2026 by
morozov
Loading…
[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…
Previous Next
ProTip!
Type g i on any issue or pull request to go back to the issue listing page.