Skip to content

Pull requests: apache/flink-cdc

New pull request New
74 Open 1,773 Closed
74 Open 1,773 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

[Docs]Update postgres-cdc.md with table-name and schema-name configs support regular expressions to monitor docs Improvements or additions to documentation
#4055 opened Jul 5, 2025 by ThorneANN Loading…
[FLINK-37958][cdc-sink-connectors] Flink CDC Sink connector support fluss 3.5 build common
#4053 opened Jul 2, 2025 by loserwang1024 Loading…
2
[FLINK-37979] Remove obsolete MySQL CDC snapshot split assigner code mysql-cdc-connector
#4048 opened Jun 21, 2025 by morozov Loading…
[FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely mongodb-cdc-connector mysql-cdc-connector oracle-cdc-connector postgres-cdc-connector
#4044 opened Jun 17, 2025 by yuxiqian Loading…
[improvement] adding runtime converter array postgres-cdc-connector
#4042 opened Jun 10, 2025 by iundarigun Loading…
1
[FLINK-37934][cdc-source-connectors] Get the case-sensitive variable names and method names of table id are not standardized, and need to be adjusted base db2-cdc-connector mongodb-cdc-connector mysql-cdc-connector mysql-pipeline-connector oracle-cdc-connector postgres-cdc-connector sqlserver-cdc-connector
#4041 opened Jun 10, 2025 by linjianchang Loading…
[FLINK-37905] Fix transform failure with non-ascii string literals composer e2e-tests runtime
#4038 opened Jun 5, 2025 by yuxiqian Loading…
[FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. debezium mongodb-cdc-connector
#4034 opened Jun 2, 2025 by Sukang1002 Loading…
4
[Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" docs Improvements or additions to documentation
#4033 opened Jun 2, 2025 by Sukang1002 Loading…
4
[FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables 3.5 mysql-cdc-connector mysql-pipeline-connector
#4032 opened May 30, 2025 by zhyayun Loading…
5
[FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization 3.5 docs Improvements or additions to documentation mysql-cdc-connector mysql-pipeline-connector
#4027 opened May 24, 2025 by yzeng1618 Loading…
@lvyanquan
12
[FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist composer
#4024 opened May 22, 2025 by aiwenmo Loading…
2
[FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of create.table Events in Flink CDC Schema Evolution 3.5 common runtime
#4015 opened May 13, 2025 by beryllw Loading…
@yuxiqian @lvyanquan
5
[FLINK-37739][cli] fix flink-conf is not obtained in local mode cli composer
#4006 opened Apr 28, 2025 by MOBIN-F Loading…
5
[FLINK-37479][postgres] Add support for PARTITIONED TABLE 3.5 docs Improvements or additions to documentation postgres-cdc-connector reviewed
#4004 opened Apr 26, 2025 by phamvinh1712 Loading…
16
[FLINK-37710] Use schemas from the state in SchemaOperator mysql-pipeline-connector runtime
#3999 opened Apr 22, 2025 by morozov • Draft
[FLINK-36796][pipeline-connector][oracle]add oracle pipeline connector. base debezium docs Improvements or additions to documentation oracle-cdc-connector
#3995 opened Apr 18, 2025 by linjianchang Loading…
31
[FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance common e2e-tests
#3994 opened Apr 18, 2025 by joyCurry30 Loading…
5
[improve] Remove repeated dependency. e2e-tests maxcompute-pipeline-connector reviewed
#3991 opened Apr 16, 2025 by joyCurry30 Loading…
2
[FLINK-37630] Support flink cdc pipeline Yarn session mode cli composer e2e-tests
#3989 opened Apr 15, 2025 by Mrart Loading…
11
[postgres] fix when backfill will scan all table schame which match config approved postgres-cdc-connector reviewed
#3985 opened Apr 10, 2025 by hql0312 Loading…
8
[FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant base common postgres-cdc-connector sqlserver-cdc-connector
#3983 opened Apr 10, 2025 by Mrart Loading…
14
[FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant mysql-cdc-connector
#3982 opened Apr 10, 2025 by Mrart Loading…
[FLINK-37585] [cdc-connector][mysql] Fixed the data of the newly added table cannot be read mysql-cdc-connector
#3973 opened Mar 30, 2025 by jeff-zou Loading…
2
[FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source 3.5 build docs Improvements or additions to documentation e2e-tests postgres-cdc-connector reviewed
#3968 opened Mar 25, 2025 by Mrart Loading…
@lvyanquan
55
ProTip! Follow long discussions with comments:>50.