zoukankan      html  css  js  c++  java
  • pyhive -- thrift.transport.TTransport.TTransportException: TSocket read 0 bytes

    Pyhive 远程连接hive出现问题:

    from pyhive import hive
    import pandas as pd
    #Create Hive connection 
    conn = hive.Connection(host="172.18.33.32", port=10000, username="hadoop", auth="NOSASL", database="log")
    # Read Hive table and Create pandas dataframe
    df = pd.read_sql("SELECT count(*) FROM record", conn)
    print(df.head())

    错误:

    Traceback (most recent call last):
      File "HiveConnect.py", line 4, in <module>
        conn = hive.Connection(host="172.18.33.32", port=10000, username="hadoop", auth="NOSASL")
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packagespyhivehive.py", line 168, in __init__
        response = self._client.OpenSession(open_session_req)
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packagesTCLIServiceTCLIService.py", line 187, in OpenSession
        return self.recv_OpenSession()
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packagesTCLIServiceTCLIService.py", line 199, in recv_OpenSession
        (fname, mtype, rseqid) = iprot.readMessageBegin()
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packages	hriftprotocolTBinaryProtocol.py", line 148, in readMessageBegin
        name = self.trans.readAll(sz)
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packages	hrift	ransportTTransport.py", line 60, in readAll
        chunk = self.read(sz - have)
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packages	hrift	ransportTTransport.py", line 162, in read
        self.__rbuf = BufferIO(self.__trans.read(max(sz, self.__rbuf_size)))
      File "C:Usersv-lijessAppDataLocalProgramsPythonPython36-32libsite-packages	hrift	ransportTSocket.py", line 132, in read
        message='TSocket read 0 bytes')
    thrift.transport.TTransport.TTransportException: TSocket read 0 bytes

    解决方案:hive-site.xml 增加下面属性,然后重启hive

  • 相关阅读:
    Kubernetes中部署MySQL
    内置函数-format()
    Jenkins-deploymnt
    一次遇到too many open files的解决详情
    一次nginx问题记录
    kickstart自动化安装系统
    Maven —— 命令行清除编译打包
    CURL 发送POST请求
    mysql的my.cnf配置参考
    利用nginx实现生产和灰度环境流量切换
  • 原文地址:https://www.cnblogs.com/Jesse-Li/p/8933776.html
Copyright © 2011-2022 走看看