2016-10-17 2 views
0

Hier Code:Hive - Python Verbindungsfehler

#!/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) 

Fehler!

Traceback (jüngste Aufforderung zuletzt): File "/usr/local/py/test.py", Zeile 8, in database = 'default') als conn: Datei „/ usr/lib /python2.6/site-packages/pyhs2/ init .py ", Zeile 7, in verbinden return Verbindung (* args, ** kwargs) Datei" /usr/lib/python2.6/site-packages/ pyhs2/connections.py“, Zeile 46, in init transport.open() Datei "/usr/lib/python2.6/site-packages/pyhs2/cloudera/thrift_sasl.py", line 55, in offen self._trans.ope n() Datei "/usr/lib64/python2.6/site-packages/thrift/transport/TSocket.py", Linie 101, in offener message = Nachricht) thrift.transport.TTransport.TTransportException: Kann keine Verbindung zu localhost: 10001

+0

Sein gelöst durch hiveServer2 Dienst starten und den Port 10000 ändern –

Antwort

0

Es durch Starten hiveServer2 Dienst aufgelöst und die Änderung der Port 10000.