如何实现Sqoop导入报ZookeeperConnectionException异常的分析

本篇文章为大家展示了如何实现Sqoop导入报Zookeeper ConnectionException异常的分析，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

公司主营业务：网站建设、成都做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联建站是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联建站推出右江免费做网站回馈大家。

环境：

CDH 6.3.0

已开启Kerberos

Java 版本: 1.8.0_181

症状表现：

在普通用户edwuser下，在一台CDH客户端节点机器上，执行以下sqoop import命令，将MySQL数据导入HBASE中：

sqoop import \--connectjdbc:mysql://db01:3306/test?characterEncoding=UTF-8 \--username root \--password mysql \--table cust_info \--hbase-tabletest:cust_info \--column-family cf \--hbase-create-table\--hbase-row-key id \-m 1

执行报错。卡在了连接Zookeeper这部分，连接被拒绝，抛出ConnectionException异常。

分析步骤：

通过日志可以看到Zookeeper连接的地址是127.0.0.1，而非集群上的Zookeeper地址，导致执行失败。

首先怀疑的是CDH相关角色客户端配置信息未正常下发，在CM界面对该客户端节点机器添加了Sqoop Gateway角色，重新下发配置；重试之后依然报同样的错误。

在CDH客户端节点服务器上，浏览/etc/hbase/conf.cloudera.hbase，以及/opt/cloudera/parcels/CDH-6.3.0-1.cdh7.3.0.p0.1279813/etc/zookeeper/conf.dist/等可能存放Zookeeper配置文件的目录。

查看之后发现所有配置文件都是已经正确下发了的，这说明和集群客户端配置部署没有关系。

此时只能换个思路前进，既然配置都正常，那么会不会是普通用户的问题呢？来试试特权用户？

切换到root用户，执行命令，发现可以成功导入，Zookeeper连接地址被正确的读取！！！

既然客户端配置下发是正常的，那么原因要么就是因为权限不足（平时普通用户通常报错的最大可能性），要么这是配置文件读的不对（比如用户读取的zookeeper配置文件在被定位到了非CDH的配置目录）。有了思路，开始进行下一步的验证。

要验证到底是不是普通用户的问题？很简单，再弄一个普通用户试试就好！

接下来，在另外一台CDH客户端节点机器上，使用普通用户登陆，执行同样的Sqoop命令，发现也能够成功导入！！！

对比两台客户端节点机器上，edwuser用户的环境变量（分别执行printenv获得这些环境变量）：

（用户的环境变量对比，左侧为有问题的机器 ，右侧为正常的机器）

发现出问题的那台机器上，edwuser用户明确定义了一些看起来命名像是hadoop级别的环境变量到.bashprofile文件，比如....HIVE_HOME变量？？？

通过搜索关键字HIVE_HOME，在一篇关于SQOOP的文章中，发现了这样的描述：

# Licensedto the Apache Software Foundation (ASF) under one or more# contributor license agreements.  Seethe NOTICE file distributed with# this work for additional information regarding copyright ownership.# The ASF licenses this file to You under the Apache License, Version2.0# (the "License"); you may not use this file except in compliancewith# the License.  You may obtain a copy of theLicense at##     http://www.apache.org/licenses/LICENSE-2.0## Unless required by applicable law or agreed to in writing, software# distributed under the License is distributed on an "AS IS"BASIS,# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express orimplied.# See the License for the specific language governing permissions and# limitations under the License.# includedin all the hadoop scripts with source command# should not be executable directly# also should not be passed any arguments, since we need original $*# SetHadoop-specific environment variables here.#Set pathto where bin/hadoop is available#hadoop的环境信息必须export HADOOP_COMM/hadoop#Set pathto where hadoop-*-core.jar is available#hadoop的mr存放目录的配置信息必须export HADOOP_MAPRED_HOME=/root/hadoop/tmp/mapred#set thepath to where bin/hbase is available#hbase的配置信息非必须export HBASE_HOME=/root/hbase#Set thepath to where bin/hive is available#hive的配置信息非必须export HIVE_HOME=/root/hive#Set thepath for where zookeper config dir is#export ZOOCFGDIR=

如果是社区版的Sqoop，是可以配置这些环境变量的。但是CDH的配置文件都统一由CM管理和下发，并不需要手工去设置到环境变量中。用户级环境变量出现这些配置，反而覆盖了CM下发的客户端配置。

由于出问题的机器上，设置的用户环境变量是HIVE_HOME=/opt/cloudera/parcels/CDH/ ，熟悉parcels目录结构的同学都知道，/opt/cloudera/parcels/CDH/这个目录的直接层次下，是不存在任何配置文件的，只有继续往下好几级的子目录中才会有配置文件。

所以sqoop执行时，会按照用户环境变量HIVE_HOME的设置，到/opt/cloudera/parcels/CDH/目录，试图读取配置文件，但没有读取到任何配置文件。所以Sqoop只能直接使用Zookeeper Server的默认值127.0.0.1。而客户端机器上当然不会存在Zookeeper Server，自然出现会拒绝连接抛出异常的问题。

解决方法：

由于当时不知道机器上这个用户环境变量HIVE_HOME，到底是谁出于什么目的设置的。就没去直接动用户环境变量文件。

先运行：

unset HIVE_HOME

来临时屏蔽HIVE_HOME这个环境变量，再执行sqoop import命令，导入成功。

上述内容就是如何实现Sqoop导入报Zookeeper ConnectionException异常的分析，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。