开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

社区首页 >专栏 >Flink 连接 hive 解决 java.net.UnknownHostException

Flink 连接 hive 解决 java.net.UnknownHostException

作者头像

shengjk1

发布于 2020-09-28 10:53:33

2.9K0

发布于 2020-09-28 10:53:33

举报

文章被收录于专栏：码字搬砖码字搬砖

错误

今天在实验 Flink 连接 hive 的操作，由于 CDH 的 hadoop 是 HA，连接过程中报错如下：

Exception in thread "main" java.lang.IllegalArgumentException: java.net.UnknownHostException: nameservice1
	at org.apache.hadoop.security.SecurityUtil.buildTokenService(SecurityUtil.java:378)
	at org.apache.hadoop.hdfs.NameNodeProxies.createNonHAProxy(NameNodeProxies.java:310)
	at org.apache.hadoop.hdfs.NameNodeProxies.createProxy(NameNodeProxies.java:176)
	at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:678)
	at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:619)
	at org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:149)
	at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2653)
	at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:92)

解决方式

1.配置 HADOOP_CONF_DIR 环境变量

2.flink-conf.yaml 配置 env.hadoop.conf.dir

3.如果是在 idea 中调试，仅仅需要在该项目的环境变量中配置如下： HADOOP_CONF_DIR=/hadoop-conf;HADOOP_USER_NAME=hdfs

其中 /hadoop-conf 中存放的是 hdfs 的配置文件

在这里插入图片描述

至此就完美解决了，可以在本地愉快的调试程序了。

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2020-09-27 ，如有侵权请联系 cloudcommunity@tencent.com 删除

面向对象编程

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体分享计划，欢迎热爱写作的你一起参与！

面向对象编程

评论

登录后参与评论

0 条评论

热度

最新

LV.

目录

错误
- 解决方式

相关产品与服务

大数据

全栈大数据产品，面向海量数据场景，帮助您 “智理无数，心中有数”！

精选特惠用云无忧