New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

TIs mysql的sink端插件暂未支持 #110

Closed

liufu1986007 opened this issue Mar 16, 2022 · 3 comments

Labels

liufu1986007 commented Mar 16, 2022

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

baisui1981 added enhancement 3.6.0 labels

Member

baisui1981 commented Mar 18, 2022 •

edited

Loading

网上找了一个实例，看起来还算简单 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
flink 版本需要升级

Member

baisui1981 commented May 9, 2022

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

Member

baisui1981 commented Nov 1, 2022

已经利用chunjun实现了

baisui1981 closed this as completed

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment