yuxiqian
|
e2b8f70e0d
|
[FLINK-37124][build] Simplify logs in test cases to avoid flooding GHA outputs
This closes #3860
|
1 month ago |
Hongshun Wang
|
bcd70df85c
|
[FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat
This closes #3667
|
1 month ago |
|
Hongshun Wang
|
12cf22f7b4
|
[FLINK-34688][cdc-connector][base] CDC framework split snapshot chunks asynchronously (#3510)
|
2 months ago |
Xin Gong
|
0037c4379e
|
[FLINK-36771][cdc-connector][base&mysql] Fix UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] (#3755)
|
3 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 |
wudi
|
7f6d9115ae
|
[FLINK-36649][cdc-connector][oracle] Fix oracle connection close error (#3678)
|
4 months ago |
gongzhongqiang
|
a5b666a325
|
[FLINK-35503] Add support for running Oracle connector unit test on ARM architecture (#3600)
|
5 months ago |
lipl
|
f6d1d4810a
|
[FLINK-35912][cdc-connector] SqlServer CDC doesn't chunk UUID-typed columns correctly (#3497)
* resolve conficts
* polish code to trigger ci
---------
Co-authored-by: Kael <kael@fts.dev>
Co-authored-by: gongzhongqiang <gongzhongqiang@gigacloudtech.com>
|
7 months ago |
|
Hongshun Wang
|
47f5660055
|
[FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter (#3319)
|
7 months ago |
ChengJie1053
|
313bace106
|
[minor][doc][cdc-connector][oracle] Update OracleSchema#getTableSchema doc description
This closes #3443.
|
7 months ago |
|
gongzhongqiang
|
c5f391cf6a
|
[FLINK-35865][base] Support Byte and Short in ObjectUtils (#3481)
|
7 months ago |
Joao Boto
|
94a0415475
|
[FLINK-34883] Fix postgres uuid column as PK (#3282)
* [FLINK-34883] Fix postgres uuid column as PK
* [FLINK-34883] Fix column comment.
|
7 months ago |
|
Xin Gong
|
2d1eb0aff1
|
[FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table (#3203)
* [cdc-connector][oracle] Oracle cdc support newly add table
* [cdc-connector][oracle] Fix code style
* [cdc-connector][oracle] Address comment
|
8 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>
|
9 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.
|
12 months ago |
|
Hang Ruan
|
eeb4bab92d
|
[FLINK-34184][cdc][license] Update Copyright from Ververica to Apache
|
12 months ago |
e-mhui
|
6da9684999
|
[cdc-connector][oracle] Use database name in upper case at the snapshot phase to fix fetching two different db name for the same table at the snapshot phase and incremental phase(#2088)
|
1 year ago |
|
e-mhui
|
ea7b0e8dbb
|
[cdc-base] Support to parse Oracle/SqlServer/PostgresSQL CDC schema change events (#2315)
|
1 year ago |
Hongshun Wang
|
1eeda75eaa
|
[cdc-connector][cdc-base] Support capture newly added tables with un-blocking stream read for CDC Framework（#3024）
|
1 year ago |
Yaroslav Tkachenko
|
1562bc29a3
|
[cdc-base] Support Scan Newly Added Tables feature
|
1 year ago |
|
Hongshun Wang
|
0ca718c31f
|
[cdc-connector][oracle] Expose SNAPSHOT_ONLY mode for Oracle CDC Source (#3005)
|
1 year ago |
|
gongzhongqiang
|
d058102c5c
|
[cdc-connector][oracle]Add oracle 21 version to OracleValidator (#3054)
|
1 year ago |
|
Hongshun Wang
|
7ea197242f
|
[debezium] Upgrade to Debezium 1.9.8.Final(#3033) (#3034)
|
1 year ago |
|
Xin Gong
|
10e542c3ff
|
[cdc-connector][sqlserver] sqlserver support use specific chunk column as a split key (#2972)
This closes #2971.
|
1 year ago |
|
Xin Gong
|
20e44e6966
|
[cdc-connector][oracle] Oracle supports user specific chunk column (#2976)
This closes #2973.
|
1 year ago |
|
Hongshun Wang
|
15a734efa0
|
[cdc-connector][oracledb] Fix oracle read exceed high_watermark in backfill phase
|
1 year ago |
|
Hongshun Wang
|
2c557c6a78
|
[cdc-connector][sqlserver][tests] Fix UT errors by correcting right output (#2864)
|
1 year ago |
|
Hongshun Wang
|
5c00f76d0f
|
[cdc-connector][oracle] Expose ability to skip backfill in snapshot period for Oracle CDC (#2793)
This closes #2793.
|
1 year ago |
yunqingmo
|
ef1c095763
|
[cdc-connector][oracle] Fix wrong table path during backfill phase which leads to potential data loss (#2707)
This closes #2707.
|
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
|
57e4793b21
|
[cdc-base] Extract the common parts of each ScanFetchTask into AbstractScanFetcherTask.
This closes #2690.
|
1 year ago |
Leonard Xu
|
7192e5300b
|
[oracle] Skip unsupported nested table for legacy debezium source function
|
1 year ago |
zyi728
|
0565bf844c
|
[oracle] Skip unsupported nested table for Incremental OracleSource
|
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 |
Maciej Bryński
|
1e6b983bdd
|
[build] Bump Flink version to 1.18.0 (#2463)
This closes #2670.
|
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 |