yuxiqian
|
e2b8f70e0d
|
[FLINK-37124][build] Simplify logs in test cases to avoid flooding GHA outputs
This closes #3860
|
3 weeks ago |
Wink
|
79e868b864
|
[FLINK-36741][transform] Fix the decimal precision and length lost during transform
This closes #3740
|
3 weeks ago |
|
yuxiqian
|
2e03f9ad49
|
[FLINK-36763][cdc-runtime] Introduce distributed schema evolution topology for sources with parallelized metadata
This closes #3801
|
2 months ago |
Hang Ruan
|
a0ae3320fa
|
[FLINK-36784][common] Support to add metadata columns for data in the meta fields of DataChangeEvent at transform (#3758)
Co-authored-by: Kunni <lvyanquan.lyq@alibaba-inc.com>
|
2 months ago |
|
yuxiqian
|
6d21941661
|
[hotfix] Fix Java 11 target compatibility & add tests (#3633)
* [hotfix] Fix Java 11 target compatibility
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
# Conflicts:
# .github/workflows/flink_cdc_java_8.yml
# .github/workflows/flink_cdc_migration_test_base.yml
# pom.xml
* fix: clarify GiHub workflow names
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
---------
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
|
2 months ago |
North Lin
|
8647fe4986
|
[FLINK-36375][cdc-runtime] Fix missed default value in AddColumnEvent/RenameColunEvent
This closes #3622.
|
3 months ago |
Hongshun Wang
|
6205a5a0f1
|
[FLINK-36094][cdc-runtime] Improve the Exception that SchemaRegistryRequestHandler thrown
This closes #3558.
|
6 months ago |
|
yuxiqian
|
78fda8b5ab
|
[FLINK-35243][cdc-common] Extends more schema change event types support
This close #3521.
|
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 |
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 |
|
yux
|
2bd2e4ce24
|
[FLINK-35121][common] Adds validation for pipeline definition options
|
8 months ago |
Kunni
|
d4ed7db8dc
|
[FLINK-35127][cdc][values] Remove HybridSource from ValuesSource to avoid CI failure. (#3237)
|
10 months ago |
|
Hongshun Wang
|
8c5437a1f1
|
[FLINK-34952][cdc-composer][sink] Flink CDC pipeline supports SinkFunction (#3204)
|
10 months ago |
wenmo
|
bcad5d9d11
|
[cdc-runtime] Introduce TransformSchemaOperator and TransformDataOperator to support transformation
|
10 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.
|
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 |
PengFei Li
|
33b7c85093
|
[pipeline-connector][starrocks] Add starrocks pipeline connector (#2765)
This closes #2645.
|
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 |
Qingsheng Ren
|
cc9d368b63
|
[cdc-composer][tests] Add integration tests for FlinkPipelineComposer (#2776)
This closes #2766.
|
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
|
8edf2a60f0
|
[cdc-pipeline-connector][values] Avoid using `default` as name of namespace and schema. (#2774)
|
1 year ago |
|
Kunni
|
4a5f2161aa
|
[cdc-pipeline-connector][values] Add event set MULTI_SPLITS_SINGLE_TABLE to mock source with multiple splits (#2737)
This closes #2737.
|
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 |
|
lvyanquan
|
b4deda97be
|
[cdc-pipeline-connector][values] Introduce `values` cdc pipeline connector
This closes #2675.
|
1 year ago |