MOBIN
|
1bf40f09cc
|
[FLINK-36093][transform] Fix preTransformoperator wrongly filters columns belong to different transforms
This closes #3572
|
3 months ago |
yuxiqian
|
086536bb30
|
[hotfix][e2e] Temporarily disable TransformE2eITCase in multiple parallelism
This closes #3718
|
4 months ago |
|
yuxiqian
|
5c1c50e2ed
|
[FLINK-36474][route] Support merging timestamp columns when routing
This closes #3693
|
4 months ago |
|
yuxiqian
|
316ea9c6ab
|
[BP-3.2][FLINK-36183][cdc-runtime] Fix lenient schema evolution failure with route blocks (#3584)
|
6 months ago |
|
yuxiqian
|
fc752fb3c8
|
[FLINK-36184][transform] Fix transform operator swallows schema changes from tables not present in transform rules (#3591)
|
6 months ago |
|
yuxiqian
|
9816848c4b
|
[hotfix][cdc-runtime] Keep upstream pending requests in order to avoid checkpoint hanging
|
6 months ago |
|
yuxiqian
|
debd43cdd7
|
[FLINK-36128][cdc-runtime] Fix potential unrecoverable in-flight data exception by promoting LENIENT as the default schema change behavior
This closes #3574.
(cherry picked from commit 2e938a92f5)
|
6 months ago |
|
yuxiqian
|
803d438657
|
[hotfix][cdc-runtime] Fix schema registry hanging in multiple parallelism
|
6 months ago |
|
yuxiqian
|
dacbe7c34a
|
[FLINK-36092][cdc-runtime] Fix schema evolution failure with wildcarded transform rule
This closes #3557.
(cherry picked from commit 3837887819)
|
6 months ago |
|
yuxiqian
|
6dd1c11fe1
|
[FLINK-36114][cdc-runtime] Make SchemaRegistryRequestHandler thread safe by blocking subsequent schemaChangeEvent
This closes #3563.
Co-authored-by: Hongshun Wang <loserwang1024@gmail.com>
(cherry picked from commit ee843e2f24)
|
6 months ago |
Hongshun Wang
|
5a80757443
|
[FLINK-36094][cdc-runtime] Improve the Exception that SchemaRegistryRequestHandler thrown
This closes #3558.
(cherry picked from commit 6205a5a0f1)
|
6 months ago |
|
yuxiqian
|
a97e2efe22
|
[FLINK-35805][transform] Add __data_event_type__ metadata column
This closes #3536
|
7 months ago |
|
yuxiqian
|
e2bb917ad0
|
[FLINK-34876][transform] Support UDF functions in transform (#3465)
|
7 months ago |
|
yuxiqian
|
81d916fc73
|
[FLINK-35272][cdc-runtime] Transform supports omitting and renaming computed column
This closes #3285.
|
7 months ago |
|
yuxiqian
|
af02ce1bc9
|
[build][e2e] Separate Pipeline and Source E2e tests and cover flink 1.20 version
This closes #3514.
|
7 months ago |
|
yuxiqian
|
5ed9e05bdf
|
[FLINK-35242][cdc-common][cdc-runtime] Support TRY_EVOLVE and LENIENT schema evolution behavior
This closes #3339.
|
7 months ago |
|
yuxiqian
|
54c6a0b207
|
[hotfix][e2e] Add missing default values field in E2e test
This closes #3516.
|
7 months ago |
Wink
|
7ca11359d7
|
[FLINK-35743][cdc-runtime] Correct the temporal function semantics
This closes #3449.
Co-authored-by: wenmo <32723967+wenmo@users.noreply.github.com>
Co-authored-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
|
7 months ago |
|
yuxiqian
|
ad1f554c0e
|
[FLINK-35647][route] Support symbol replacement to enrich routing rules
This closes #3428.
Co-authored-by: 张田 <zhang_tian@inspur.com>
Co-authored-by: yangshuaitong <duguhoney@gmail.com>
|
8 months ago |
|
yux
|
3441a1e2ab
|
[FLINK-35648][runtime] Allow applying multiple route rules for one single source table (#3425)
|
8 months ago |
|
yuxiqian
|
8eb7e53965
|
[FLINK-35120][doris] Add Doris integration test cases
|
9 months ago |
|
yuxiqian
|
d8a9c8c63e
|
[FLINK-35316][base] Run E2e test cases with Flink 1.19 and latest patch versions
|
9 months ago |
|
yux
|
88afc5f18d
|
[FLINK-35323][cdc-runtime] Fix transform failure when one rule matches multiple tables with incompatible schema
This closes #3313.
|
9 months ago |
|
yux
|
f61f0f44bd
|
[FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3280)
|
10 months ago |
|
yux
|
de4be372f8
|
[hotfix][e2e] Fix pipeline e2e test cases failures (#3246)
|
10 months ago |
Kunni
|
bc7031bd71
|
[e2e][pipeline-connector][mysql] Add e2e test for mysql pipeline connector
This closes #2997.
|
10 months ago |
xleoken
|
5f4f86fb31
|
[hotfix] Change old com.ververica dependencies to org.apache.flink (#3110)
|
11 months ago |
Hang Ruan
|
eeb4bab92d
|
[FLINK-34184][cdc][license] Update Copyright from Ververica to Apache
|
12 months 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 |