-
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
[chore][test] Fix flaky postgres pipeline test case
postgres-pipeline-connector
#4293
opened Feb 28, 2026 by
Hisoka-X
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-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive
mysql-pipeline-connector
#4284
opened Feb 24, 2026 by
sd4324530
Loading…
[FLINK-38828][cdc-runtime] Add state persistence to PostTransformOperator for projection schema evolution
#4280
opened Feb 24, 2026 by
VinaySagarGonabavi
Loading…
[FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes
#4279
opened Feb 23, 2026 by
VinaySagarGonabavi
Loading…
FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING
#4278
opened Feb 15, 2026 by
morozov
Loading…
[FLINK-39055] [Iceberg] Support default column values in Iceberg sink connector
#4277
opened Feb 13, 2026 by
suhwan-cheon
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-37485][starrocks] Add support for TIME type
approved
docs
Improvements or additions to documentation
reviewed
starrocks-pipeline-connector
#4253
opened Feb 1, 2026 by
Hisoka-X
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
[FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01.
postgres-cdc-connector
#4214
opened Jan 8, 2026 by
lvyanquan
Loading…
[FLINK-38831][route] The route configuration supports matching the first one
cli
common
composer
docs
Improvements or additions to documentation
e2e-tests
runtime
#4212
opened Jan 5, 2026 by
linguoxuan
Loading…
Previous Next
ProTip!
Add no:assignee to see everything that’s not assigned.