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.
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即可。
发布于:3个月前 (03-20) IP属地:未知
我来回答