tis icon indicating copy to clipboard operation
tis copied to clipboard

Published 20 hours ago • verified publisher icon datavane

TIs mysql的sink端插件暂未支持

Open liufu1986007 opened this issue 2 years ago • 2 comments

1、TIs mysql的sink端插件暂未支持 2、如何快速适配最新版本的flink、flink-cdc等流行插件版本？

liufu1986007 avatar Mar 16 '22 01:03 liufu1986007

  1. 网上找了一个实例，看起来还算简单 https://blog.csdn.net/xianpanjia4616/article/details/88762069?utm_term=flink%E5%AE%9E%E7%8E%B0mysqlsink&utm_medium=distribute.pc_aggpage_search_result.none-task-blog-2~all~sobaiduweb~default-2-88762069&spm=3001.4430, 或者可以参考 flinkx的一个实现 https://github.com/flinkx/flinkx/blob/2772041ad84fe3c1a34dccc30c0dca4899c78f18/flinkx-core/src/main/java/com/flink/flinkx/streaming/api/functions/sink/DtOutputFormatSinkFunction.java#L58 MysqlWriter.java
  2. flink 版本需要升级

baisui1981 avatar Mar 18 '22 01:03 baisui1981

https://github.com/DTStack/chunjun/blob/v1.12.2/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/sink/MysqlSinkFactory.java

baisui1981 avatar May 09 '22 10:05 baisui1981

已经利用chunjun实现了

baisui1981 avatar Nov 01 '22 08:11 baisui1981