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

Flink sql中加载hive报错：Could not find any factory for identifier 'hive' that implements

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

在flink中加载hive的时候报错了，提示：

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.ModuleFactory' in the classpath.

Available factory identifiers are:

core

现在要怎么办？

Flink Hive

发布于：1年前 (2023-08-24) IP属地：四川省

1 个回答

吹南风

这是因为没有吧hive相关的依赖添加搭配flink的执行环境中去，去下面的地址，下载个flink-connector-hive包即可，下载地址是：

https://mvnrepository.com/artifact/org.apache.flink/flink-connector-hive

注意下载的版本需要和flink版本，scala版本保持一致。

发布于：1年前 (2023-08-24) IP属地：四川省

我来回答