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.
1 个回答
你是我此生最美的风景
你是我此生最美的风景
这是由于使用了flinkcdc,但是没有引入flinkcdc-mysql的包,去这里下载mysql依赖包:
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就可以了。
发布于:2个月前 (03-20) IP属地:未知
我来回答