Skip to content

Pull requests: apache/flink-cdc

New pull request New
60 Open 1,878 Closed
60 Open 1,878 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[PROPOSAL] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector mysql-cdc-connector
#4170 opened Nov 4, 2025 by tejanshrana • Draft
[FLINK-38618][base] Fix reassign stream split cause offset error when startup mode is latest-offset and taskManager failover base sqlserver-cdc-connector
#4169 opened Nov 4, 2025 by gong • Review required
3
[FLINK-38620][pipeline-connector][iceberg] fixed iceberg metrics NullPointerException iceberg-pipeline-connector
#4168 opened Nov 4, 2025 by fcfangcc • Review required
[FLINK-38568][mysql-cdc] Optimize binlog split lookup using binary search mysql-cdc-connector
#4166 opened Oct 27, 2025 by huyuanfeng2018 • Review required
1
[FLINK-38531][cdc-connector-mysql]Fix data loss when restoring from a checkpoint positioned in the middle of a bulk DML operation. mysql-cdc-connector
#4165 opened Oct 25, 2025 by 5herhom • Review required
@lvyanquan
1
Add Hudi sink connector support build e2e-tests
#4164 opened Oct 24, 2025 by voonhous • Review required
22
[FLINK-38522][cdc connector mysql] use ssl for BinaryLogClient when searching for binlog offset for starting mysql cdc from timestamp mysql-cdc-connector reviewed
#4156 opened Oct 14, 2025 by watsonjo737 • Review required
5
[FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism approved iceberg-pipeline-connector reviewed
#4150 opened Oct 9, 2025 by fcfangcc • Approved
5
[FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector build docs Improvements or additions to documentation
#4145 opened Sep 25, 2025 by locchipinti • Draft
[FLINK-38413] Adding support for append only tables to MySQL Pipeline connector e2e-tests mysql-cdc-connector mysql-pipeline-connector
#4137 opened Sep 23, 2025 by junmuz • Review required
7
[FLINK-38110] fix PostgreSQL connector reads Chinese columns with garbled charactor postgres-cdc-connector
#4128 opened Sep 21, 2025 by qingfei1994 • Review required
[FLINK-38279] Add SnapshotPendingSplitsState to MySQL checkpoint stat… mysql-cdc-connector
#4127 opened Sep 19, 2025 by dwash96 • Review required V3.6.0
3
Support MySQL in-source parallel deserialization mysql-cdc-connector
#4122 opened Sep 17, 2025 by saligia-tju • Draft
1
[FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement mysql-cdc-connector
#4117 opened Sep 14, 2025 by suhwan-cheon • Review required V3.6.0
@lvyanquan
8
Implement comma-separated parsing for chunk key columns base docs Improvements or additions to documentation postgres-cdc-connector
#4115 opened Sep 9, 2025 by xxntti3n • Review required
4
[FLINK-38239][oceanbase] Re-enable OceanBase CDC integration tests in CI with Docker image docs Improvements or additions to documentation e2e-tests mysql-cdc-connector oceanbase-cdc-connector
#4111 opened Aug 28, 2025 by yuanoOo • Review required
3
[FLINK-38250] The Flink CDC type supports the timeTZ field type. common
#4107 opened Aug 22, 2025 by Mrart • Draft
[FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… paimon-pipeline-connector
#4106 opened Aug 22, 2025 by tbpure • Review required
1
[FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. mysql-cdc-connector
#4098 opened Aug 15, 2025 by danzhewuju • Review required
[FLINK-38218] Fix MySQL CDC binlog split metadata split transmission mysql-cdc-connector
#4087 opened Aug 8, 2025 by morozov • Review required
@lvyanquan
1
[draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema debezium mysql-cdc-connector
#4083 opened Aug 7, 2025 by czy006 • Review required
[pipeline-connector/paimon] Support table specific table.properties configuration paimon-pipeline-connector
#4078 opened Aug 6, 2025 by nickdelnano • Review required
5
[FLINK-38183] Fix the problem of data loss in the GTID disordered scenario mysql-cdc-connector
#4072 opened Aug 3, 2025 by lzshlzsh • Draft
2
[FLINK-38139] Fix consecutive online schema change causes job failure. mysql-cdc-connector mysql-pipeline-connector
#4064 opened Jul 24, 2025 by lvyanquan • Review required
3
[improvement] adding runtime converter array postgres-cdc-connector
#4042 opened Jun 10, 2025 by iundarigun • Review required
6
ProTip! Updated in the last three days: updated:>2025-11-01.