我正在Hive queries
使用Python
. PyHive
其中一个查询大约需要 12-15 分钟才能完成。我可以看到它完成了Hadoop
ResourceManager UI
,但是我看到下面的超时错误Python
。
错误:回溯(最后一次调用):文件“/home/mrjadav/python/thunderbolt.py”,第 704 行,在 main() 文件“/home/mrjadav/python/thunderbolt.py”,第 662 行,在 main getColoLatency() 文件“/home/mrjadav/python/thunderbolt.py”,第 582 行,在 getColoLatency dataSet = saveHqlResultToXls(queryString=queryString, caption='Colo Latency Breakdown', configuration=g_hive_config_heavy) 文件“/home/mrjadav/python /thunderbolt.py”,第 636 行,在 saveHqlResultToXls dataSet=cursor.fetchall() 文件“/home/y/lib/python2.7/site-packages/pyhive/common.py”,第 136 行,在 fetchall 返回列表中( iter(self.fetchone, None)) 文件“/home/y/lib/python2.7/site-packages/pyhive/common.py”,第 105 行,在 fetchone self._fetch_while(lambda: not self._data and self ._state != 自我。_STATE_FINISHED) 文件“/home/y/lib/python2.7/site-packages/pyhive/common.py”,第 45 行,在 _fetch_while self._fetch_more() 文件“/home/y/lib/python2.7/site -packages/pyhive/hive.py”,第 386 行,在 _fetch_more 响应 = self._connection.client.FetchResults(req) 文件“/home/y/lib/python2.7/site-packages/TCLIService/TCLIService.py” ,第 714 行,在 FetchResults 返回 self.recv_FetchResults() 文件 "/home/y/lib/python2.7/site-packages/TCLIService/TCLIService.py",第 726 行,在 recv_FetchResults (fname, mtype, rseqid) = iprot .readMessageBegin() 文件“/home/y/lib/python2.7/site-packages/thrift/protocol/TBinaryProtocol.py”,第 134 行,在 readMessageBegin sz = self.readI32() 文件“/home/y/lib /python2.7/site-packages/thrift/protocol/TBinaryProtocol.py”,第 217 行,在 readI32 buff = self.trans.readAll(4) 文件“/home/y/lib/python2.7/site-packages/thrift/transport/TTransport.py”,第 60 行,在 readAll 块 = self.read(sz - 有)文件“/home/y/lib/python2.7/site-packages/thrift_sasl/init .py”,第 166 行,在读取 self._read_frame() 文件“/home/y/lib/python2.7/site-packages/thrift_sasl/init .py ”,第 170 行,在 _read_frame header = self._trans 中。 readAll(4) 文件“/home/y/lib/python2.7/site-packages/thrift/transport/TTransport.py”,第 60 行,在 readAll 块 = self.read(sz - have) 文件“/home/ y/lib/python2.7/site-packages/thrift/transport/TSocket.py",第 117 行,读取 buff = self.handle.recv(sz) 错误:[Errno 110] 连接超时