Dinky运行flink sql任务报错,提示:Could not find any factory for identifier 'mysql-cdc'
Dinky运行flink sql任务报错,提示:
Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'mysql-cdc' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
发布于:4个月前 (03-20) IP属地:未知
1 个回答
![你是我此生最美的风景 你是我此生最美的风景](https://www.80wz.com/zb_users/avatar/0.png)
这是由于使用了flinkcdc,但是没有引入flinkcdc-mysql的包,去这里下载mysql依赖包:
把他放在dinky的flink依赖包里面,然后重启dinky就可以了。
https://repo.maven.apache.org/maven2/com/alibaba/ververica/flink-sql-connector-mysql-cdc/1.4.0/flink-sql-connector-mysql-cdc-1.4.0.jar
把他放在dinky的flink依赖包里面,然后重启dinky就可以了。
发布于:4个月前 (03-20) IP属地:未知
我来回答
您需要 登录 后回答此问题!