全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

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.

Dinky Flink

发布于：1年前 (2024-03-20) IP属地：未知

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就可以了。

发布于：1年前 (2024-03-20) IP属地：未知

我来回答