-
Notifications
You must be signed in to change notification settings - Fork 2.2k
Pull requests: apache/flink-cdc
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-40513][runtime] Introduce multimodal AI functions for image understanding
add-ons
common
composer
docs
Improvements or additions to documentation
runtime
#4520
opened Sep 1, 2026 by
haruki-830
Contributor
Loading…
1 task done
[FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter.
base
mongodb-cdc-connector
postgres-cdc-connector
#4519
opened Aug 31, 2026 by
loserwang1024
Contributor
Loading…
1 task
[FLINK-35104] [pipeline-connector/kafka]support pipeline kafka source
build
common
composer
docs
Improvements or additions to documentation
e2e-tests
kafka-pipeline-connector
paimon-pipeline-connector
runtime
starrocks-pipeline-connector
#4518
opened Aug 31, 2026 by
MOBIN-F
Contributor
Loading…
[FLINK-36605] Bump debezium to last 2.x version
base
build
db2-cdc-connector
debezium
e2e-tests
mysql-cdc-connector
mysql-pipeline-connector
oceanbase-cdc-connector
oracle-cdc-connector
postgres-cdc-connector
postgres-pipeline-connector
sqlserver-cdc-connector
vitess-cdc-connector
#4516
opened Aug 28, 2026 by
eskabetxe
Member
Loading…
1 task done
[FLINK-40473] Fix yarn-application mode failing to locate flink-cdc-dist jar with Flink version suffix
composer
#4514
opened Aug 26, 2026 by
llphxd
Contributor
Loading…
[oracle] Support specific-offset startup mode with SCN for Oracle pipeline source
#4510
opened Aug 18, 2026 by
fightBoxing
Loading…
[FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader
docs
Improvements or additions to documentation
mysql-cdc-connector
mysql-pipeline-connector
#4509
opened Aug 17, 2026 by
hadoopkandy
Loading…
2 tasks done
[FLINK-40432][connect/tidb] Split key ranges by TiKV region via FLIP-27 enumerator
docs
Improvements or additions to documentation
tidb-cdc-connector
#4508
opened Aug 17, 2026 by
lifulong
Loading…
1 task done
[FLINK-40385][postgre]Optimize efficiency issues of PostgreSQL during the full snapshot phase.
postgres-cdc-connector
#4506
opened Aug 12, 2026 by
hql0312
Contributor
Loading…
[FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink.
approved
common
docs
Improvements or additions to documentation
reviewed
runtime
#4498
opened Aug 5, 2026 by
loserwang1024
Contributor
Loading…
1 task
[FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source
#4497
opened Aug 4, 2026 by
leosanqing
Loading…
1 task done
[hotfix][postgres] generateCreateTableEvent result is skipped
postgres-pipeline-connector
#4490
opened Jul 24, 2026 by
CatOrLeader
Contributor
Loading…
1 task
[FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent
base
#4489
opened Jul 24, 2026 by
dev-donghwan
Loading…
[cdc-connector][oracle] Support row_id metadata column and fix headers loss in JdbcSourceFetchTaskContext
base
oracle-cdc-connector
#4487
opened Jul 24, 2026 by
fightBoxing
Loading…
[oracle] Support row_id metadata column for Oracle CDC (with headers-loss bug fix)
#4486
opened Jul 24, 2026 by
fightBoxing
Loading…
[FLINK-40203][runtime] Add an explicit option for Flink SQL-compatible YAML Transform expression semantics
cli
common
composer
docs
Improvements or additions to documentation
runtime
#4484
opened Jul 23, 2026 by
haruki-830
Contributor
Loading…
[hotfix][runtime] Return UNKNOWN for null regex LIKE predicates
runtime
#4483
opened Jul 23, 2026 by
wolfkill
Loading…
1 task done
[FLINK-40204][runtime] Introduce statement-level codegen for YAML Transform expressions
composer
runtime
#4482
opened Jul 22, 2026 by
haruki-830
Contributor
Loading…
[FLINK-40201] Fix Oracle CDC compatibility with Oracle 26ai and Debezium 3.4.2.Final
#4481
opened Jul 21, 2026 by
Suhel0328
Loading…
1 task done
[FLINK-40146][connect/starrocks] Support AlterTableCommentEvent in StarRocks sink
docs
Improvements or additions to documentation
starrocks-pipeline-connector
#4477
opened Jul 17, 2026 by
haruki-830
Contributor
Loading…
[FLINK-40533] Upgrade supported Flink versions to 2.3
build
e2e-tests
kafka-pipeline-connector
mongodb-cdc-connector
mysql-cdc-connector
postgres-cdc-connector
sqlserver-cdc-connector
tidb-cdc-connector
#4475
opened Jul 15, 2026 by
yuxiqian
Member
Loading…
1 task done
[FLINK-40148][common] Fix TableIdRouter producing wrong sink table for multi-digit source suffix
common
runtime
#4473
opened Jul 14, 2026 by
sd4324530
Contributor
Loading…
1 task done
[FLINK-34807][mysql] Add MariaDB GTID support
mysql-cdc-connector
#4468
opened Jul 11, 2026 by
leosanqing
Loading…
[FLINK-40102][mysql]Support batch emitting CreateTableEvents to reduce schema coordination overhead
docs
Improvements or additions to documentation
mysql-cdc-connector
mysql-pipeline-connector
#4466
opened Jul 9, 2026 by
eric666666
Contributor
Loading…
Previous Next
ProTip!
Mix and match filters to narrow down what you’re looking for.