yuxiqian
|
4d0174c79c
|
[FLINK-36565][transform] Route allows merging Decimals with various precisions (#3743)
|
2 months ago |
|
yuxiqian
|
6fb19e612b
|
[FLINK-36461][transform] Fix schema evolution failure with un-transformed tables
This closes #3721.
|
2 months ago |
|
yuxiqian
|
5c1c50e2ed
|
[FLINK-36474][route] Support merging timestamp columns when routing
This closes #3693
|
3 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)
|
5 months ago |
|
yuxiqian
|
dacbe7c34a
|
[FLINK-36092][cdc-runtime] Fix schema evolution failure with wildcarded transform rule
This closes #3557.
(cherry picked from commit 3837887819)
|
5 months ago |
Hongshun Wang
|
5a80757443
|
[FLINK-36094][cdc-runtime] Improve the Exception that SchemaRegistryRequestHandler thrown
This closes #3558.
(cherry picked from commit 6205a5a0f1)
|
5 months ago |
Qingsheng Ren
|
4e985ceb27
|
[FLINK-36054][cdc][build] Fix Flink CDC parent pom and release scripts (#3541)
|
6 months ago |
Kunni
|
64f996b504
|
[FLINK-35891][pipeline-connector][paimon] Support dynamic bucket in Paimon sink
This closes #3499.
|
6 months ago |
|
yuxiqian
|
e2bb917ad0
|
[FLINK-34876][transform] Support UDF functions in transform (#3465)
|
6 months ago |
Hang Ruan
|
07446d1f9d
|
[FLINK-35715][common] Ignore the compact optimize for mysql timestamp type in BinaryRecordData (#3511)
|
6 months ago |
|
yuxiqian
|
81d916fc73
|
[FLINK-35272][cdc-runtime] Transform supports omitting and renaming computed column
This closes #3285.
|
6 months ago |
|
yuxiqian
|
5ed9e05bdf
|
[FLINK-35242][cdc-common][cdc-runtime] Support TRY_EVOLVE and LENIENT schema evolution behavior
This closes #3339.
|
6 months ago |
lvyanquan
|
4561a8a32b
|
[FLINK-34638][cdc-common] Support column with default value
|
6 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>
|
6 months ago |
|
Hongshun Wang
|
d76beecdb0
|
[FLINK-35234][minor][cdc-common] Fix potential NPE in ConfigurationUtils
This closes #3255.
|
6 months ago |
Leonard Xu
|
26ff6d2a08
|
[FLINK-35237][cdc-common] Improve the interfaces and reorganize the directory.
|
6 months ago |
鼎昕
|
9a4dede3fe
|
[FLINK-35237][cdc-common] Allow Sink to choose HashFunction in PrePartitionOperator
|
6 months ago |
|
yuxiqian
|
a098ddacba
|
[FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs
This closes #3458.
|
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>
|
7 months ago |
|
yux
|
2bd2e4ce24
|
[FLINK-35121][common] Adds validation for pipeline definition options
|
8 months ago |
North Lin
|
c958daf8ab
|
[FLINK-35540][cdc-common] Fix table missed when database and table are with the same name
This closes #3396.
|
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>
|
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 |
|
Kunni
|
c1e1aa48d9
|
[FLINK-34648][cdc] Avoid RPC timeout when applying SchemaChangeEvent to downstream external systems
This closes #3128.
|
9 months ago |
|
Kunni
|
ef2eece256
|
[pipeline-connector][paimon] add paimon pipeline data sink connector. (#2916)
|
9 months ago |
|
Qingsheng Ren
|
6017b16528
|
[FLINK-34653][cdc][route] Support table merging with route rules
This closes #3129.
|
10 months ago |
Qishang Zhong
|
18dd51fe22
|
[FLINK-34905][cdc-connector][mysql] Fix the default length of CHAR/BINARY data type of Add column DDL (#3145)
|
10 months ago |
xleoken
|
6510e670fa
|
[FLINK-34959][cdc] Update old flink-cdc-connectors artifactId (#3200)
|
10 months ago |
wenmo
|
c92903016d
|
[cdc-common] Introduce partitionKeys into schema and add related util classes
|
10 months ago |
|
Qishang Zhong
|
d099603ef1
|
[FLINK-34948][cdc][common] Fix cdc RowType can not convert to Flink type
|
10 months ago |
|
xleoken
|
5f4f86fb31
|
[hotfix] Change old com.ververica dependencies to org.apache.flink (#3110)
|
10 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 |
|
joyCurry30
|
c98f899af8
|
[cdc-common][cdc-pipelines][cdc-runtime] Use name instead of column in DropColumnEvent/AddColumnEvent. (#2888)
|
1 year ago |
|
Kunni
|
146ed9d0be
|
[hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize
This closes #2943
|
1 year ago |
|
joyCurry30
|
055b0af477
|
[cdc-common][pipeline-doris] Fix typo and wrong value for 'precision' of time type. (#2886)
|
1 year ago |
|
Qingsheng Ren
|
9415260a25
|
[cdc-common][hotfix] Remove redundant prefix of pipeline options (#2821)
This closes #2821.
|
1 year ago |
|
Kunni
|
4abd86a500
|
[pipeline-connector][doris] add doris pipeline connector. (#2810)
Co-authored-by: wudi <676366545@qq.com>
|
1 year ago |
|
Hang Ruan
|
1766e82d7c
|
[3.0][cdc-common & runtime] Remove useless flink imports
|
1 year ago |
Jiabao Sun
|
174282d3ef
|
[cdc-pipeline-connector][mysql] Support more mysql types
|
1 year ago |
|
Jiabao Sun
|
d0cce26b76
|
[cdc-pipeline-connector][mysql] Introduce mysql cdc pipeline DataSource
|
1 year ago |
Leonard Xu
|
95921d5620
|
[cdc-common] Introduce "pipeline.local-time-zone" config option which help handle time zone well (#2797)
This closes #2797.
|
1 year ago |
|
Hang Ruan
|
e435004eda
|
[cdc-common][hotfix] Remove useless flink imports (#2803)
This closes #2803.
|
1 year ago |
|
Kunni
|
b60322bef7
|
[pipeline-common] Use column name to check whether the schema contains specific column or not. (#2801)
This closes #2801.
|
1 year ago |
|
Qingsheng Ren
|
2bde0beaec
|
[cdc-common] Introduce AssertJ-style assertion system for Flink CDC data structures
|
1 year ago |
|
Kunni
|
a81d4a16b9
|
[cdc-common] Introduce createFieldGetters method in SchemaUtils to build FieldGetters of given Schema. (#2762)
This closes #2762.
|
1 year ago |
|
Kunni
|
3806c72ef8
|
[cdc-common] add PublicEvolving annotation to SchemaUtils (#2756)
|
1 year ago |
gongzhongqiang
|
0cdfd36c08
|
[3.0][cdc-composer] Introduce pipeline.name config to support custom flink job name (#2768)
Co-authored-by: Leonard Xu <leonard@apache.org>
This closes #2769.
|
1 year ago |
|
Hang Ruan
|
70614be28c
|
[3.0][cdc-common] Introduce BinaryRecordDataGenerator to help to create BinaryRecordData
This closes #2734.
|
1 year ago |
|
Hang Ruan
|
cad7424a1d
|
[3.0][cdc-common] Use BinaryRecordData in DataChangeEvent instead of GenericRecordData
|
1 year ago |