Skip to content

Pull requests: apache/flink-cdc

New pull request New
163 Open 1,197 Closed
163 Open 1,197 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Fix sqlserver uniqueidentifier column as PK sqlserver-cdc-connector
#3497 opened Jul 26, 2024 by LiPL2017 Loading…
[docs][minor] Add transform piece for pipeline example docs Improvements or additions to documentation
#3496 opened Jul 25, 2024 by leonardBang Loading…
[FLINK-35894] Add Elasticsearch Sink Connector for Flink CDC Pipeline
#3495 opened Jul 25, 2024 by proletarians Loading…
15
[FLINK-35888][cdc-connector][paimon] Add e2e test for PaimonDataSink. e2e-tests reviewed
#3491 opened Jul 23, 2024 by lvyanquan Loading…
11
[FLINK-35884][mysql-pipeline-connector] MySQL pipeline support snapshot chunk key-column mysql-pipeline-connector
#3490 opened Jul 23, 2024 by beryllw Loading…
@ruanhang1993
[cdc-runtime]SchemaRegistry Log output is repeated runtime
#3487 opened Jul 23, 2024 by ChengJie1053 Loading…
1
[FLINK-35873][cdc-connector][paimon] Add HashFunctionProvider implementation for PaimonDataSink. paimon-pipeline-connector
#3486 opened Jul 22, 2024 by lvyanquan Loading…
[minor][cdc-connector][mysql] catch all exceptions to display the table info mysql-pipeline-connector
#3485 opened Jul 22, 2024 by lvyanquan Loading…
[minor][cdc-runtime]The processedTableIds add is executed twice reviewed runtime
#3483 opened Jul 20, 2024 by ChengJie1053 Loading…
1
[FLINK-34865][pipeline-connector]support sync table and column comments common composer docs Improvements or additions to documentation doris-pipeline-connector mysql-pipeline-connector
#3482 opened Jul 19, 2024 by qg-lin Loading…
1
[docs] Support the version mapping between pipeline connectors and flink docs Improvements or additions to documentation reviewed
#3478 opened Jul 17, 2024 by shiyiky Loading…
1
[docs] Add schema evolution type supporting status for pipeline sink connectors docs Improvements or additions to documentation
#3475 opened Jul 16, 2024 by yuxiqian • Draft
1
[FLINK-35072][doris] Support applying AlterColumnTypeEvent to Doris sink doris-pipeline-connector
#3473 opened Jul 15, 2024 by yuxiqian Loading…
5
[Kafka]Kafka sink numRecordsOutByIncremental metrics runtime
#3471 opened Jul 12, 2024 by ChengJie1053 Loading…
4
pipeline add param scan.newly-added-table.enabled mysql-pipeline-connector
#3470 opened Jul 12, 2024 by yangup Loading…
1
[FLINK-35813][runtime] Do not clear state field in TSO until operator was closed runtime
#3469 opened Jul 11, 2024 by yuxiqian Loading…
2
[FLINK-35805][transform] Add __row_kind__ metadata column composer docs Improvements or additions to documentation reviewed runtime
#3468 opened Jul 10, 2024 by yuxiqian Loading…
5
[FLINK-35757][mysql] support dynamically capture new tables mysql-cdc-connector mysql-pipeline-connector
#3467 opened Jul 10, 2024 by Karl-WangSK Loading…
[FLINK-34876][transform] Support UDF functions in transform cli composer docs Improvements or additions to documentation runtime
#3465 opened Jul 10, 2024 by yuxiqian Loading…
1
[FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. mysql-cdc-connector
#3463 opened Jul 10, 2024 by lvyanquan Loading…
4
[FLINK-35791][kafka] add database and table info of canal/debezium json format for kafka sink. docs Improvements or additions to documentation kafka-pipeline-connector
#3461 opened Jul 9, 2024 by lvyanquan Loading…
4
[minor][test] Remove duplicate test code mysql-cdc-connector
#3460 opened Jul 8, 2024 by Karl-WangSK Loading…
1
[cdc-connector][mysql]Mysql add numRecordsOutBySnapshot and numRecordsOutByIncremental metrics mysql-cdc-connector
#3456 opened Jul 6, 2024 by ChengJie1053 Loading…
11
[FLINK-35774][cdc-runtime] Fix the cache of transform is not updated after process schema change event composer runtime
#3455 opened Jul 6, 2024 by aiwenmo Loading…
2
[FLINK-35762] Cache hashCode for TableID & Transform descriptors common runtime
#3454 opened Jul 5, 2024 by yuxiqian Loading…
1
ProTip! Filter pull requests by the default branch with base:master.