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 |
Qingsheng Ren
|
4e985ceb27
|
[FLINK-36054][cdc][build] Fix Flink CDC parent pom and release scripts (#3541)
|
7 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
|
241eb03a74
|
[FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0
This closes #3489.
|
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.
|
8 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 |
|
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 |
|
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 |
Leonard Xu
|
8deddab6eb
|
[minor][cdc-connector][db2] Fix typos and improve the code style
|
10 months ago |
gong
|
3385ae8fbc
|
[cdc-connector][db2] Db2 support incremental source
|
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 |
|
yux
|
01ec7da989
|
[FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages (#3212)
|
10 months ago |
xleoken
|
6510e670fa
|
[FLINK-34959][cdc] Update old flink-cdc-connectors artifactId (#3200)
|
11 months ago |
|
xleoken
|
5f4f86fb31
|
[hotfix] Change old com.ververica dependencies to org.apache.flink (#3110)
|
11 months ago |
|
Kunni
|
26eb6a99b9
|
[hotfix][cdc][build] Include cdc-common module when shaded for module flink-sql-connector-mysql-cdc
|
12 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 |
gongzhongqiang
|
a24c5d1b24
|
[cdc][e2e] Unify logic to clean docker image when connector e2e test finished (#2978)
|
1 year ago |
He Wang
|
4616092195
|
[cdc-source-connector][oceanbase][e2e] Add OceanBase e2e test case (#2521)
This closes #981
|
1 year ago |
|
Qingsheng Ren
|
c0ee1c188e
|
[build] Skip maven-deploy-plugin for test modules and flink-cdc-dist
|
1 year ago |
|
gongzhongqiang
|
51554d8630
|
[hotfix][vitess] Fix invalidate package name
This closes #2735.
|
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 |
gongzhongqiang
|
3cf64106c9
|
[oracle] Refactor oracle unit test
|
1 year ago |
|
gongzhongqiang
|
aec2a91c81
|
[e2e] Remove db docker image after test cases are executed. (#2508)
|
1 year ago |
|
Hongshun Wang
|
6ca87c4d57
|
[tests][e2e] add log config to e2e tests (#2464)
|
1 year ago |
|
yuxiqian
|
44cd46e227
|
[mongodb][hotfix] Mongo CDC fails to capture collections with `.` in names (#2488)
|
1 year ago |
|
Leonard Xu
|
c6bfa0edfa
|
[e2e] Remove flink 1.13 tests from e2e test matrix
|
1 year ago |