-
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-39066][pipeline-connector][Fluss] fix the metric histogram always return null
#4281
opened Feb 24, 2026 by
ThorneANN
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-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on
isTableIdCaseInsensitive.
#4276
opened Feb 13, 2026 by
sd4324530
Loading…
[ci] Specify Docker API version explicitly as a workaround of testcontainers/testcontainers-java#11212
#4275
opened Feb 13, 2026 by
yuxiqian
Loading…
[pipeline] Use GHA workflow triggers to run labeler workflow
#4274
opened Feb 11, 2026 by
yuxiqian
Loading…
Select fileds rathert * to read snapshot data in case schema changes.
#4273
opened Feb 11, 2026 by
loserwang1024
Loading…
[FLINK-38455] Fix ES8 pipeline connector failure when batch contains only SchemaChangeEvents
#4270
opened Feb 10, 2026 by
Hisoka-X
Loading…
[FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector
#4267
opened Feb 9, 2026 by
Hisoka-X
Loading…
[test] Improve pipeline connector test coverage i.e. doris/postgres/fluss
#4266
opened Feb 9, 2026 by
leonardBang
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
docs
Improvements or additions to documentation
starrocks-pipeline-connector
#4253
opened Feb 1, 2026 by
Hisoka-X
Loading…
[FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors
docs
Improvements or additions to documentation
#4247
opened Jan 30, 2026 by
ThorneANN
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!
Type g i on any issue or pull request to go back to the issue listing page.