全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言机器学习

Dinky运行flink sql任务报错，提示：Cannot discover a connector using option: 'connector'='elasticsearch-7'

提问者：帅平问题分类：大数据

Dinky运行flink sql任务报错，提示：

Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'elasticsearch-7' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

Dinky Flink Elasticsearch

发布于：4个月前 (03-20) IP属地：未知

1 个回答

巴黎小甜心

这是由于使用了flinkcdc把数据同步到elasctisearch，缺少依赖包，去如下的地址下载：

https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.11/1.13.5/flink-sql-connector-elasticsearch7_2.11-1.13.5.jar

然后把包放在flink的依赖目录后重启dinky即可。

发布于：4个月前 (03-20) IP属地：未知

我来回答