相关的依赖以及添加,不知道如下问题是如何导致,求解!
已添加的依赖有:
flink-connector-mysql-cdc
flink-format-changelog-json
flink-json
报错信息如下:
java.util.ServiceConfigurationError: org.apache.flink.table.factories.Factory:
Provider com.alibaba.ververica.cdc.formats.json.ChangelogJsonFormatFactory
could not be instantiated
at jav
估计是你的 flink-json 和框架已经打包进去的 flink-json 冲突了,可能是你加进去的 flink-json 版本不是 1.11.x ?
On Fri, 27 Nov 2020 at 19:03, cljb...@163.com wrote:
> 相关的依赖以及添加,不知道如下问题是如何导致,求解!
> 已添加的依赖有:
> flink-connector-mysql-cdc
> flink-format-changelog-json
> flink-json
>
> 报错信息如下:
>
> java.util.ServiceConfigurationError:
>
感谢回复!
刚才找到问题了,从maven官网拷贝过来的 pom依赖, scope被设置成 test了。。。改成compile就好了
cljb...@163.com
发件人: Jark Wu
发送时间: 2020-11-27 19:14
收件人: user-zh
主题: Re: flink sql cdc 写数据到mysql,找不到相关的类
估计是你的 flink-json 和框架已经打包进去的 flink-json 冲突了,可能是你加进去的 flink-json 版本不是 1.11.x ?
On Fri, 27 Nov 2020 at 19:03, cljb...@163