Przeglądaj źródła

[impala] Retrying and opening a new session if previous one has expired

Romain Rigaux 11 lat temu
rodzic
commit
68be9b6b62

+ 1 - 1
apps/beeswax/src/beeswax/server/hive_server2_lib.py

@@ -426,7 +426,7 @@ class HiveServerClient:
 
 
     # Not supported currently in HS2 and Impala: TStatusCode.INVALID_HANDLE_STATUS
     # Not supported currently in HS2 and Impala: TStatusCode.INVALID_HANDLE_STATUS
     if res.status.statusCode == TStatusCode.ERROR_STATUS and \
     if res.status.statusCode == TStatusCode.ERROR_STATUS and \
-        re.search('Invalid SessionHandle|Invalid session', res.status.errorMessage or '', re.I):
+        re.search('Invalid SessionHandle|Invalid session|Client session expired', res.status.errorMessage or '', re.I):
       LOG.info('Retrying with a new session because for %s of %s' % (self.user, res))
       LOG.info('Retrying with a new session because for %s of %s' % (self.user, res))
 
 
       session = self.open_session(self.user)
       session = self.open_session(self.user)