Commit Graph

1238 Commits (master)
 

Author SHA1 Message Date
Hongshun Wang 3bf886b94d [cdc-connector][mysql] Add SNAPSHOT_ONLY mode for Mysql CDC Source (#2901) 1 year ago
Hongshun Wang 35d3c0ff28
[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSplitSize from recovery in 4th version
This closes #2992.
1 year ago
Kunni 146ed9d0be
[hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize
This closes #2943
1 year ago
gongzhongqiang a24c5d1b24
[cdc][e2e] Unify logic to clean docker image when connector e2e test finished (#2978) 1 year ago
He Wang f3762a1b30
[pipeline-connector][mysql] fix timestamp with timezone format (#2952)
* fix ts with tz parser

* test timestamp with default value

* fix related test

* use timestamp string in test cases
1 year ago
Kunni 557944488b
[doc] fix invalid page in website and update yaml in tutorial.
This closes #2966.
1 year ago
Hongshun Wang 15a734efa0 [cdc-connector][oracledb] Fix oracle read exceed high_watermark in backfill phase 1 year ago
张田 1b643026fe
[pipeline-connector][starrocks] Optimize char type mapping for starrocks pipeline connector (#2895) 1 year ago
Kunni 812c33d27b
[pipeline-connector][doris][starrocks] Remove SimpleDateFormat for thread safe (#2954) 1 year ago
FocusComputing b42bc60ab9
[source-connector][mysql] speedup searching binlog by timestamp (#2924)
* [feature] speedup search mysql binlog when mysql-cdc-connector consume binlog by timestamp

* improve code

* improve code

* code improve

* test case add and code improve

* code improve

* code improve

* code improve, ut add and bugfix for purged log

---------

Co-authored-by: TJX2014 <tangjinxin@deepexi.com>
1 year ago
Kunni 7ab1e87842
[build] Add github labeler for pipeline connector. (#2851) 1 year ago
He Wang cebfe2e5ca
[docs][cdc-connector][oceanbase] update docker image and os compatibility in quickstart (#2897)
* [docs][cdc-connector] update docker image and description in oceanbase quickstart

* revert removal by accident
1 year ago
TorinJie c12c44d969
[docs] Add Supported Connectors and Supported Flink Versions to Overview. (#2920) 1 year ago
joyCurry30 055b0af477
[cdc-common][pipeline-doris] Fix typo and wrong value for 'precision' of time type. (#2886) 1 year ago
Leonard Xu a5fa2dc6c8
[hotfix][cdc-connector][mysql] Expose row_kind metadata column for mysql cdc source. (#2927)
We use 'row_kind' name instead of 'op' or 'op_type', the operation type is a concept of database and database only has 'update'
type and hasn't 'update_before' and 'update_after' type.
1 year ago
Xianxun Ye 8eba910063
[cdc-connector][mysql] Support metadata 'operation' virtual column for MySql Connector. (#2913) 1 year ago
Hongshun Wang 6b6d9fcb0b
[cdc-connector][mongodb] Avoid mongodb source to read data after high_watermark in backfill phase (#2893) 1 year ago
He Wang 26dfeeb563
[cdc-connector][oceanbase] Fallback to current timestamp when query gts failure (#2868) 1 year ago
Hongshun Wang 2c557c6a78
[cdc-connector][sqlserver][tests] Fix UT errors by correcting right output (#2864) 1 year ago
skylines 1839fb556c
[hotfix][docs] Change the title to keep the document format uniform (#2871) 1 year ago
GOODBOY008 08beca52d0 [cdc] Add Deprecated annotation to source function which connector implemented incremental 1 year ago
GOODBOY008 f7d6adc28b [hotfix] Remove mysqlToDoris.yml 1 year ago
GOODBOY008 f2c81c7d08 [hotfix] Fix BinaryRecordData deserialize 1 year ago
Hongshun Wang 568ed79005
[postgres] Add commits of PostgresConnection back to distinguish with debezium's origin class (#2839) 1 year ago
xuzifu666 e6bb8e9a55
[hotfix][cdc-rumtime][minor] Clean up useless code in BinaryRecordDataSerializer (#2845)
Co-authored-by: xuyu <11161569@vivo.com>
1 year ago
PengFei Li f2c0a03269
[pipeline-connector][starrocks][docs] Fix the pictures do not display (#2860) 1 year ago
wudi 12836e5560
[docs][pipeline-connector][doris] Introduce Doris Pipeline Connector (#2788) 1 year ago
PengFei Li 78dc8ba9e7
[docs][pipeline-connector][starrocks] Add documents for StarRocks pipeline connector (#2840)
This close #2840.
1 year ago
Kunni 8be7bdd25d
[3.0][docs] Add tutorial for mysql to starrocks pipeline (#2841) 1 year ago
Xin Gong 08d6b8178f
[cdc-connector][sqlserver] Fix SqlServerTableSource params order error (#2847) 1 year ago
Kunni 43bd5c01b2
[3.0][docs] Add tutorial for mysql to doris pipeline. (#2838) 1 year ago
Hongshun Wang f15faac298
[docs] Fix overview docs to remove prefix of pipeline options (#2833) 1 year ago
Shawn Huang b9615db694
[3.0][docs] fix mysql pipeline connector option in readme (#2834) 1 year ago
Jiabao Sun 2088f89ed8
[3.0][docs] Add documents for MySql pipeline connector (#2827) 1 year ago
Hongshun Wang f2c2e64491
[3.0][docs] Introduce core concepts for CDC 3.0 pipeline (#2790)
This closes #2655.
1 year ago
Shawn Huang db5743ce00
[docs] Add CDC pipeline example in README (#2819)
Co-authored-by: guiyuan.hx <guiyuan.hx@alibaba-inc.com>
1 year ago
PengFei Li 72bcb1df02
[pipeline-connector][starrocks] Fix char/varchar length inconsistency between cdc and starrocks (#2829) 1 year ago
gongzhongqiang c484bb447c
[build][hotfix] Remove duplicate dependency (#2828) 1 year ago
Qingsheng Ren 6cb2ffe2fb
[cdc-cli][cdc-composer] Use "source-table" and "sink-table" as keywords of route (#2823) 1 year ago
Qingsheng Ren 73086c4f37
[cdc-cli][cdc-dist] Support loading global config from FLINK_CDC_HOME (#2822)
This closes #2822.
1 year ago
Qingsheng Ren 9415260a25
[cdc-common][hotfix] Remove redundant prefix of pipeline options (#2821)
This closes #2821.
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 0c8f5eaf0a [build] Use flink-shaded-force-shading to force all submodules to generate dependency-reduced-pom.xml
This will erase all properties in dependency-reduced-pom.xml and
pin all properties to a constant value. For example, ${flink.version}
will be replaced by the actual Flink version, which is safer for users
to reference it.
1 year ago
Qingsheng Ren daceb42168 [build] Use ${project.version} instead of ${revision} for dependency version
This is documented in https://maven.apache.org/maven-ci-friendly.html#dependencies
1 year ago
Qingsheng Ren c0ee1c188e [build] Skip maven-deploy-plugin for test modules and flink-cdc-dist 1 year ago
Jiabao Sun 8a08ded410
[cdc-pipeline-connector][mysql] Fix precision problem of BIT type conversion (#2820)
This closes #2820.
1 year ago
Dian Qi f970444efa
[cdc-source-connector][mysql] fix deserialization issue on table metadata binlog event (#2682)
Co-authored-by: EchoLee5 <39044001+EchoLee5@users.noreply.github.com>
1 year ago
Jiabao Sun 7d7c1af553
[pipeline-connector][mysql] Remove unnecessary serverTimeZone in DebeziumEventDeserializationSchema (#2816) 1 year ago
Leonard Xu 18fb0d8b7f
[build][hotfix] Remove useless suppressions. (#2817) 1 year ago
Josh Mahonin 63b39ba22c
[cdc-source-connector][mysql] Fix attempted load of isSuspended in MySqlSplitSerializer::deserializeSplit when cdc version <= 2.2.0 (#2550)
Co-authored-by: Hang Ruan <ruanhang1993@hotmail.com>
1 year ago