Thanks, you are a genius 🙂 . Installing thrift-sasl-0.4.2 and impyla 0.16.2 did allow successful running of the script. However now I have a different issue. The call cursor.fetchmany(size=3) hangs indefinitely in Jupyter notebook. It executes immediately in similar pyhive script on same small table. from impala.dbapi import connect conn = connect(host='myhost', port=21050, auth_mechanism='GSSAPI', kerberos_service_name='impala') cursor = conn.cursor() cursor.execute('SELECT * FROM default.mytable LIMIT 100') cursor.fetchmany(size=3) cursor.close() conn.close() It show query status as Executing in Cloudera manager->Impala Queries monitor. But also says Query State: FINISHED in the query details . The hang seems to be in the statement buff = self.sock.recv(sz) /data/opt/anaconda3/lib/python3.7/site-packages/thriftpy2/transport/socket.py in read (self, sz)
107 while True :
108 try :
--> 109 buff = self . sock . recv ( sz )
110 except socket . error as e :
111 if e . errno == errno . EINTR :
KeyboardInterrupt : After trying various options and setting timeout=100 in the connect statement, it appears the script queries impala table successfully but every 2nd or 3rd time it fails with the below error: /data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in _rpc (self, func_name, request)
992 response = self . _execute ( func_name , request )
993 self . _log_response ( func_name , response )
--> 994 err_if_rpc_not_ok ( response )
995 return response
996
/data/opt/anaconda3/lib/python3.7/site-packages/impala/hiveserver2.py in err_if_rpc_not_ok (resp)
746 resp . status . statusCode != TStatusCode . SUCCESS_WITH_INFO_STATUS and
747 resp.status.statusCode != TStatusCode.STILL_EXECUTING_STATUS):
--> 748 raise HiveServer2Error ( resp . status . errorMessage )
749
750
HiveServer2Error : Invalid query handle: b14cce8e19xxxx:5b51463xxxx
Any more thoughts?
... View more
