Loreon
Labs
Platform
Docs
Home
Ecosystems
Java
flink-cdc
Test
Java
Emerging
GitHub
Stars
2
Forks
4
Contributors
8
Last push
6h ago
Recent commits
Latest commits.
[FLINK-38723][common/composer] Add getFlinkConf method to Context. (#4179)
7ad789e
Kunni
7mo ago
[FLINK-38641][cdc/mysql] Unquote double quotes from default values on MySQL (#4171)
25fa95e
Junbo Wang
7mo ago
[FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174)
55aff6e
Tejansh
7mo ago
[FLINK-38618][base] Fix offset error due to duplicated stream split during TM failover if startup mode is latest-offset
4bab367
Xin Gong
7mo ago
[FLINK-38491][pipeline-connector][iceberg] fixed iceberg compaction parallelism (#4150)
cfaf3cb
fcfangcc
7mo ago
[FLINK-38279][mysql] Add SnapshotPendingSplitsState to MySQL checkpoint state during restoration
6767d85
Dustin Washington
7mo ago
[FLINK-38568] [mysql-cdc] [cdc-base] Optimize binlog split lookup using binary search
7a6bfd8
big face cat
7mo ago
[FLINK-38680][build] Bump Flink 1.19 and 1.20 patch versions
27dee1f
big face cat
7mo ago
Top contributors
Builders behind this project.
leonardBang
187 commits
yuxiqian
135 commits
lvyanquan
102 commits
GOODBOY008
98 commits
ruanhang1993
91 commits
loserwang1024
81 commits
wuchong
67 commits
PatrickRen
66 commits