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

Flink sql中加载hive报错：ClassNotFoundException: org.apache.hadoop.io.Writable

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

flink sql里面加载hive的时候报错了，提示：

[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.hadoop.io.Writable

现在怎么办？

Flink Hive

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

1 个回答

有你我就幸福

这是缺少hadoop的相关依赖，查看下对应需要使用的hadoop版本，如果是hadoop2的话，在下面的地址下载依赖添加到flink的执行环境中去：

https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop-2

如果是hadoop3的话，则在下面地址在下依赖添加到flink的执行环境中去:

https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop-3

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

我来回答