yuxiqian
|
8eb7e53965
|
[FLINK-35120][doris] Add Doris integration test cases
|
8 months ago |
|
yuxiqian
|
d8a9c8c63e
|
[FLINK-35316][base] Run E2e test cases with Flink 1.19 and latest patch versions
|
8 months ago |
|
yuxiqian
|
fe1ceb9ff6
|
[FLINK-35415][base] Bump Flink patch version to 1.18.1
|
8 months ago |
|
yuxiqian
|
9a9603413c
|
[FLINK-35415][base] Fix compatibility with Flink 1.19
|
8 months ago |
|
yux
|
414720d1c5
|
[FLINK-35464][cdc] Fixes operator state backwards compatibility from CDC 3.0.x and add migration tests (#3369)
|
8 months ago |
joyCurry30
|
8a7fdd5ae3
|
[minor][cdc-connector][paimon] Remove duplicate interface implements
|
8 months ago |
|
yux
|
b1e157468a
|
[FLINK-35527][docs] Polish quickstart guide & migrate maven links from ververica to apache
|
8 months ago |
Leonard Xu
|
e817cc283d
|
[minor][docs] Improve the readme and issue template
This closes #3383.
|
8 months ago |
Paul Lin
|
53c2fb9772
|
[build][hotfix] Fix jackson conflicts among cdc connectors
This closes #2987.
|
8 months ago |
|
joyCurry30
|
0214166049
|
[FLINK-35325][cdc-connector][paimon] Support specify column order when adding new columns to a table
This closes #3323.
|
8 months ago |
Muhammet Orazov
|
5b28d1a579
|
[FLINK-35129][postgres] Introduce scan.lsn-commit.checkpoints-num-delay option to control LSN offset commit lazily
This close #3349.
|
8 months ago |
Hongshun Wang
|
33891869a9
|
[FLINK-35149][cdc-composer] Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink (#3233)
|
8 months ago |
|
joyCurry30
|
0e8b2c7cc5
|
[FLINK-35430][cdc-connector][kafka] Pass the time zone infor to JsonSerializationSchema
This closes #3359.
|
8 months ago |
|
yux
|
88afc5f18d
|
[FLINK-35323][cdc-runtime] Fix transform failure when one rule matches multiple tables with incompatible schema
This closes #3313.
|
8 months ago |
Shawn Huang
|
19c382c0f2
|
[FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method
This closes #3342.
|
8 months ago |
|
yux
|
4a8b587510
|
[minor][cdc-cli] Suppress false alarm in flink config loader
This closes #3292.
|
8 months ago |
gongzhongqiang
|
d97124fb9f
|
[FLINK-35447][doc-ci] Flink CDC Document document file had removed but website can access
This closes #3362.
|
8 months ago |
|
Shawn Huang
|
b2cb30f240
|
[FLINK-35408][mysql] Introduce 30 minutes tolerance when validate the time-zone setting
This closes #3341.
|
8 months ago |
|
Shawn Huang
|
6350eec66c
|
[FLINK-35301][cdc] Avoid deadlock when loading driver classes
This closes #3300.
|
8 months ago |
|
Shawn Huang
|
18b0627e34
|
[FLINK-35295][mysql] Improve jdbc connection pool initialization failure message
This closes #3293.
|
8 months ago |
|
Shawn Huang
|
bddcaae784
|
[FLINK-35294][mysql] Use source config to check if the filter should be applied in timestamp starting mode
This closes #3291.
|
8 months ago |
|
Shawn Huang
|
8e8fd304af
|
[FLINK-35298][cdc][metrics] Improve the fetch delay metrics
This closes #3298.
|
8 months ago |
|
gongzhongqiang
|
644b5c2ce1
|
[FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 to avoid dead links
This closes #3351.
|
8 months ago |
PONYLEE
|
b33e6a047d
|
[minor][docs] Improve the answer of MySQL CDC FAQ docs
This closes #3337.
|
8 months ago |
|
gongzhongqiang
|
d386c7c1c2
|
[FLINK-35386][cdc][docs] Shorten GHA names and disable fail-fast to isolate branches (#3331)
|
9 months ago |
|
gongzhongqiang
|
999027fbb1
|
[FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable (#3330)
|
9 months ago |
Wink
|
d0457f7d24
|
[FLINK-35314][cdc] Add Flink CDC pipeline transform user document (#3308)
|
9 months ago |
|
yux
|
8d2d2a65d9
|
[hotfix][docs] Fix dead links in documentations
This closes #3314.
|
9 months ago |
|
yux
|
0f5584b20a
|
[minor][docs] Rectify names of CDC sources for Flink and improve the content directory
This closes #3310.
|
9 months ago |
Xie Yi
|
fa6e7ea512
|
[FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc
|
9 months ago |
Junbo wang
|
b6cfbccd36
|
[hotfix][docs] Correct example configuration for Paimon warehouse path
|
9 months ago |
Xin Gong
|
a7cb46f762
|
[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT
|
9 months ago |
|
Xie Yi
|
002b16ed4e
|
[FLINK-35244][cdc-connector][tidb] Correct the package for flink-connector-tidb-cdc test
|
9 months ago |
|
yux
|
f61f0f44bd
|
[FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3280)
|
9 months ago |
yanghuaiGit
|
23a67dcdb9
|
[FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3271)
|
9 months ago |
|
Wink
|
75a553eb92
|
[FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228)
|
9 months ago |
|
Wink
|
0108d0e5d1
|
[FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278)
|
9 months ago |
|
yux
|
4609f5f155
|
[minor][docs] Fix route definition example in core concept docs (#3269)
|
9 months ago |
|
yux
|
6258bec5bb
|
[FLINK-35256][cdc][runtime] Fix transform node does not respect type nullability (#3272)
|
9 months ago |
|
yux
|
a513e9f82e
|
[FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3276)
|
9 months ago |
Qingsheng Ren
|
9cc3451ddf
|
[FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation
This closes #3267.
|
9 months ago |
Kunni
|
ec643c9dd7
|
[FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
|
9 months ago |
|
yux
|
185f71978d
|
[minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs
|
9 months ago |
ConradJam
|
6232d84052
|
[FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240)
|
9 months ago |
Zmm
|
f9c1ecafff
|
[docs][hotfix] Correct shell scripts style in Quickstart document
This closes #3253.
|
9 months ago |
|
Qingsheng Ren
|
b0e053838c
|
[release] Update version to 3.2-SNAPSHOT
This closes #3261.
|
9 months ago |
He Wang
|
05281e5d6f
|
[FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector (#3124)
|
9 months ago |
|
Hongshun Wang
|
bdca0e328b
|
[FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230)
|
9 months ago |
Leonard Xu
|
ddf557c8e1
|
[tests][cdc-connector][db2] Improve the DB2 tests
This closes #2870
|
9 months ago |
|
Leonard Xu
|
8deddab6eb
|
[minor][cdc-connector][db2] Fix typos and improve the code style
|
9 months ago |