Hongshun Wang
|
12cf22f7b4
|
[FLINK-34688][cdc-connector][base] CDC framework split snapshot chunks asynchronously (#3510)
|
2 months ago |
liuxiaodong
|
ee9cd828c3
|
[FLINK-36315][cdc-connector][base&pg&mongodb]The flink-cdc-base module supports source metric statistics (#3619)
Co-authored-by: molin.lxd <molin.lxd@alibaba-inc.com>
Co-authored-by: Hang Ruan <ruanhang1993@hotmail.com>
|
2 months ago |
Hang Ruan
|
23e8149e6a
|
[FLINK-36803][cdc-connector][base & mysql] Use the same format `tableId:chunkId` for splitId in SnapshotSplit (#3763)
|
2 months ago |
ConradJam
|
dd79a02f0f
|
[FLINK-36586][build] Update flink version to 1.19 (#3660)
Co-authored-by: ConradJam <czy006@apache.com>
Co-authored-by: Hang Ruan <ruanhang1993@hotmail.com>
|
3 months ago |
yuxiqian
|
daf27fa7a8
|
[hotfix][test] Reorganize test cases
|
4 months ago |
Jiabao Sun
|
aea2b6aa9c
|
[hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest cannot run (#3555)
|
6 months ago |
|
yuxiqian
|
b937db25d5
|
[hotfix][cdc-connector][mongodb] Fix unstable test cases for snapshot back-filling (#3506)
|
6 months ago |
|
yuxiqian
|
241eb03a74
|
[FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0
This closes #3489.
|
7 months ago |
|
yux
|
17ff659ff7
|
[hotfix][build] Remove test-jar from parent pom and only add to necessary modules
This closes #3397.
Co-authored-by: Qingsheng Ren <renqschn@gmail.com>
|
8 months ago |
|
yuxiqian
|
0562e35da7
|
[FLINK-35079][cdc-connector][mongo] Fallback to timestamp startup mode when resume token has expired
|
10 months ago |
|
Hongshun Wang
|
48ca8623bb
|
[FLINK-34634][cdc-base][mysql] Fix that Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed (#3134)
|
10 months ago |
|
yuxiqian
|
1b0b9f868d
|
[minor][cdc-connector][mongo] Fix warning during MongoDB tests (#3210)
|
10 months ago |
xleoken
|
5f4f86fb31
|
[hotfix] Change old com.ververica dependencies to org.apache.flink (#3110)
|
11 months ago |
|
Hang Ruan
|
e10c8691ad
|
[FLINK-34584][cdc][build] Rename package from com.ververica to org.apache.flink
This closes #3089.
|
11 months ago |
|
Hang Ruan
|
eeb4bab92d
|
[FLINK-34184][cdc][license] Update Copyright from Ververica to Apache
|
11 months ago |
Hongshun Wang
|
a2ad627fed
|
[cdc-connector][mongodb] Expose capture newly added tables ability to Mongodb CDC source
|
12 months ago |
|
Hongshun Wang
|
1eeda75eaa
|
[cdc-connector][cdc-base] Support capture newly added tables with un-blocking stream read for CDC Framework（#3024）
|
12 months ago |
Yaroslav Tkachenko
|
1562bc29a3
|
[cdc-base] Support Scan Newly Added Tables feature
|
12 months ago |
|
yuxiqian
|
82ccf00e6a
|
[hotfix][cdc-connector][mongodb] Fix scanFullChangelog requires all collections
|
1 year ago |
|
Hongshun Wang
|
a2d36a892e
|
[cdc-connector][mongodb][hotfix] Stop executing log reading in MongoDBStreamFetchTask#close (#3029)
This closes #3029.
|
1 year ago |
|
Hongshun Wang
|
e3f6829263
|
[cdc-connector][mongodb] Add SNAPSHOT_ONLY mode for Mongodb CDC Source
|
1 year ago |
|
Hongshun Wang
|
6b6d9fcb0b
|
[cdc-connector][mongodb] Avoid mongodb source to read data after high_watermark in backfill phase (#2893)
|
1 year ago |
|
Hongshun Wang
|
2c557c6a78
|
[cdc-connector][sqlserver][tests] Fix UT errors by correcting right output (#2864)
|
1 year ago |
GOODBOY008
|
08beca52d0
|
[cdc] Add Deprecated annotation to source function which connector implemented incremental
|
1 year ago |
|
Hongshun Wang
|
e7c713eca6
|
[cdc-connector][mongodb] Expose ability to skip backfill in snapshot period for Mongodb CDC.
|
1 year ago |
|
Hongshun Wang
|
4e248fad33
|
[cdc-connector][base] Support skip snapshot backfill for incremental snapshot connector
|
1 year ago |
|
Hongshun Wang
|
13be14fe3f
|
[cdc-connector][base][tests] Introduce snapshot phase hooks for better snapshot test
|
1 year ago |
|
Hongshun Wang
|
cc9dbc6660
|
[mongodb][hotfix] Fix MongoDB's rewriteOutputBuffer to emit +I rather than +U (#2760) (#2760)
|
1 year ago |
|
Hongshun Wang
|
57e4793b21
|
[cdc-base] Extract the common parts of each ScanFetchTask into AbstractScanFetcherTask.
This closes #2690.
|
1 year ago |
Shawn Huang
|
18936a3676
|
[mongodb] Incremental snapshot source supports comma-separated format parameter for databases and collections (#2724)
|
1 year ago |
Leonard Xu
|
995d524416
|
[3.0][common] Use built-in API annotations to make common module free with flink
This closes #2695.
|
1 year ago |
joyCurry30
|
d01f0a9791
|
[pom] Use ${revision} replace specific version. (#2623)
|
1 year ago |
|
Leonard Xu
|
82a652ca6f
|
[3.0][kickoff] Introduce basic modules for Flink CDC 3.0
This closes #2610
|
1 year ago |