Anyone found an answer for this I am also getting same error when I run below. This is a kerberos cluster and Impala works fine through HUE and odbc: -------------------- from impala.dbapi import connect conn = connect(host='myhost', port=21050) cursor = conn.cursor() cursor.execute('SELECT * FROM default.testtable') print (cursor.description) # prints the result set's schema results = cursor.fetchall() ---------------------------------------------------------------------------
HiveServer2Error Traceback (most recent call last)
<ipython-input-13-82112a6ffca2> in <module> ()
2 conn = connect ( host = 'myhost' , port = 21050 )
3
----> 4 cursor = conn . cursor ( )
5 cursor . execute ( 'SELECT * FROM default.testtable' )
6 print ( cursor . description ) # prints the result set's schema
/data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in cursor (self, user, configuration, convert_types, dictify, fetch_error)
122 log . debug ( '.cursor(): getting new session_handle' )
123
--> 124 session = self . service . open_session ( user , configuration )
125
126 log.debug('HiveServer2Cursor(service=%s, session_handle=%s, '
/data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in open_session (self, user, configuration)
1062 username = user ,
1063 configuration=configuration)
-> 1064 resp = self . _rpc ( 'OpenSession' , req )
1065 return HS2Session(self, resp.sessionHandle,
1066 resp . configuration ,
/data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in _rpc (self, func_name, request)
990 def _rpc ( self , func_name , request ) :
991 self . _log_request ( func_name , request )
--> 992 response = self . _execute ( func_name , request )
993 self . _log_response ( func_name , response )
994 err_if_rpc_not_ok ( response )
/data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in _execute (self, func_name, request)
1021
1022 raise HiveServer2Error('Failed after retrying {0} times'
-> 1023 .format(self.retries)) 1024
1025 def _operation ( self , kind , request ) :
HiveServer2Error : Failed after retrying 3 times --------------------------------------------------- Next I tried adding the kerberos parms: conn = connect(host='myhost', port=21050, auth_mechanism='GSSAPI', kerberos_service_name='impala') Now get a different error: /data/opt/anaconda3/lib/python3.7/site-packages/thrift_sasl/__init__.py in open (self)
65
66 def open ( self ) :
---> 67 if not self . _trans . isOpen ( ) :
68 self . _trans . open ( )
69
AttributeError : 'TSocket' object has no attribute 'isOpen'
... View more
