为了账号安全,请及时绑定邮箱和手机立即绑定

Hive的Thrift连接报错

Hive的Thrift连接报错

若鸟 2017-08-24 16:47:19
package demo.hive; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.transport.TSocket; import org.apache.thrift.protocol.TProtocol; import org.apache.hadoop.hive.service.ThriftHive; import java.util.List; /**  * Created by Administrator on 2017/8/24.  */ public class HiveThriftclient {     public static void main(String[] args) throws Exception{         //创建Socket连接         final TSocket tSocket = new TSocket("192.168.0.108",10000);         //创建协议         final  TProtocol tProtcal = new TBinaryProtocol(tSocket);         //创建一个连接         final ThriftHive.Client client = new ThriftHive.Client(tProtcal);         //打开Socket         tSocket.open();         //执行HQL语句         client.execute("desc job51");         //处理结果         List<String> columns = client.fetchAll();         for(String col:columns){             System.out.println(col);         }         //释放资源         tSocket.close();     } }报错信息SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".SLF4J: Defaulting to no-operation (NOP) logger implementationSLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.Exception in thread "main" org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect    at org.apache.thrift.transport.TSocket.open(TSocket.java:187)    at demo.hive.HiveThriftclient.main(HiveThriftclient.java:23)Caused by: java.net.ConnectException: Connection refused: connect    at java.net.DualStackPlainSocketImpl.connect0(Native Method)    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)    at java.net.Socket.connect(Socket.java:589)    at org.apache.thrift.transport.TSocket.open(TSocket.java:182)    ... 1 morehiveserver2启动信息 hiveserver2 ls: cannot access /root/app/spark-2.1.0-bin-2.6.0-cdh5.7.0/lib/spark-assembly-*.jar: No such file or directorywhich: no hbase in (/root/app/sqoop-1.4.6.bin__hadoop-0.23/bin:/root/app/spark-2.1.0-bin-2.6.0-cdh5.7.0/bin:/root/app/hive-1.1.0-cdh5.7.0/bin:/root/app/hadoop-2.6.0-cdh5.7.0/bin:/root/app/scala-2.11.8/bin:/root/app/apache-maven-3.3.9/bin:/root/app/jdk1.7.0_51/bin:/usr/lib64/qt-3.3/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/root/bin)哪位大神帮忙瞅瞅
查看完整描述

目前暂无任何回答

  • 0 回答
  • 0 关注
  • 4054 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信