-
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
[hotfix][docs] Fix broken stable docs URL in outdated/unreleased banner
docs
Improvements or additions to documentation
#4469
opened Jul 12, 2026 by
spuru9
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…
[FLINK-40087][mysql] Fix MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g.
_UTF8MB4" 0 ")
mysql-cdc-connector
#4464
opened Jul 7, 2026 by
gong
Contributor
Loading…
[FLINK-39429][cdc-base] Avoid shaded Guava in incremental source fetchers
base
#4462
opened Jul 5, 2026 by
qiuyanjun888
Loading…
[FLINK-39613][runtime] Unquote schema metadata keys
runtime
#4461
opened Jul 5, 2026 by
qiuyanjun888
Loading…
[FLINK-40051][pipeline-connector/hudi] Fix schema operator UID with operator UID prefix
#4460
opened Jul 5, 2026 by
qiuyanjun888
Loading…
[FLINK-40052][mysql] Roll back assigner status in addSplits to prevent NPE in createBinlogSplit
mysql-cdc-connector
reviewed
#4459
opened Jul 2, 2026 by
linguoxuan
Contributor
Loading…
[FLINK-40038][pipeline-connector/mysql] Cache inferred row DataType in MySQL deserialization
debezium
mysql-pipeline-connector
#4458
opened Jul 2, 2026 by
monologuist
Loading…
[FLINK-40040][cdc-runtime] Wrap coordinator failure in SerializedThrowable across the RPC boundary
e2e-tests
runtime
values-pipeline-connector
#4456
opened Jul 1, 2026 by
Zhile
Loading…
[FLINK-39976][pipeline-connector/db2] Add DB2 Pipeline connector
db2-cdc-connector
docs
Improvements or additions to documentation
#4454
opened Jun 29, 2026 by
Daishuyuan
Contributor
Loading…
[FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect
postgres-cdc-connector
reviewed
#4453
opened Jun 29, 2026 by
JNSimba
Member
Loading…
[FLINK-40005][cdc-cli] CliExecutor application mode resolves pipeline definition from local path (k8s), remote path or inline content
cli
docs
Improvements or additions to documentation
#4451
opened Jun 29, 2026 by
Zhile
Loading…
[FLINK-39965][runtime] Correct schema state after DropTableEvent
runtime
#4448
opened Jun 22, 2026 by
taoran92
Member
Loading…
[FLINK-35104][pipeline-connector/kafka] Add kafka pipeline data source connector
e2e-tests
kafka-pipeline-connector
#4445
opened Jun 18, 2026 by
dyp12
Loading…
[FLINK-39950][sqlserver] Fix chunk key column search restricted to primary key columns
sqlserver-cdc-connector
#4443
opened Jun 17, 2026 by
jubins
Contributor
Loading…
1 task done
[FLINK-38647][CDC] Improve error message for null before/after struct…
debezium
postgres-pipeline-connector
#4439
opened Jun 8, 2026 by
BreadS00
Loading…
[FLINK-38647] Support changelog-mode=upsert + null-tolerance
postgres-pipeline-connector
runtime
#4437
opened Jun 4, 2026 by
cansakiroglu
Loading…
[FLINK-34806][postgres] Expose scan.newly-added-table.enabled option
postgres-pipeline-connector
#4436
opened Jun 4, 2026 by
cansakiroglu
Loading…
[FLINK-39844][postgres] Filter snapshot table columns by schema name to fix LIKE-wildcard cross-schema column leakage
postgres-cdc-connector
#4435
opened Jun 4, 2026 by
JNSimba
Member
Loading…
[FLINK-39843][oracle-cdc] Support Oracle XStream streaming
oracle-cdc-connector
#4434
opened Jun 4, 2026 by
paulo-t
Loading…
[FLINK-39842][oracle-cdc] Support timestamp startup by resolving SCN
oracle-cdc-connector
#4433
opened Jun 4, 2026 by
paulo-t
Loading…
[FLINK-39841][oracle-cdc] Add option to skip analyze table before chunk planning
oracle-cdc-connector
#4432
opened Jun 4, 2026 by
paulo-t
Loading…
[FLINK-39840][pipeline-connector/oracle] Fix Oracle pipeline table identifiers
#4431
opened Jun 4, 2026 by
paulo-t
Loading…
[hotfix] Guard Optional.get() in Kafka and StarRocks connector schema lookups
kafka-pipeline-connector
starrocks-pipeline-connector
#4430
opened Jun 4, 2026 by
dangzitou
Loading…
Previous Next
ProTip!
Type g p on any issue or pull request to go back to the pull request listing page.