【发布时间】:2016-10-17 14:22:56
【问题描述】:
这里是代码:
#!/usr/bin/env python
import pyhs2
try:
with pyhs2.connect(host='localhost',
port=10001,
authMechanism="PLAIN",
user='root',
password='test',
database='test') as conn:
with conn.cursor() as cur:
#Show databases
print cur.getDatabases()
#Execute query
cur.execute("select * from raw_stats")
#Return column info from query
print cur.getSchema()
#Fetch table results
for i in cur.fetch():
print i
except Thrift.TException, tx:
print '%s' % (tx.message)
错误!
Traceback(最近一次调用最后一次):文件“/usr/local/py/test.py”,行 8、在database='default') as conn: File “/usr/lib/python2.6/site-packages/pyhs2/init.py”,第 7 行,在 连接 返回 Connection(*args, **kwargs) 文件“/usr/lib/python2.6/site-packages/pyhs2/connections.py”,第 46 行,在 初始化 transport.open() 文件“/usr/lib/python2.6/site-packages/pyhs2/cloudera/thrift_sasl.py”,行 55,在公开 self._trans.open() 文件“/usr/lib64/python2.6/site-packages/thrift/transport/TSocket.py”,行 101,在公开 message=message) thrift.transport.TTransport.TTransportException: 无法连接到 localhost:10001
【问题讨论】:
-
通过启动 hiveServer2 服务并更改端口 10000 解决