Просмотр исходного кода

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

Romain Rigaux 11 лет назад
Родитель
Сommit
68be9b6
1 измененных файлов с 1 добавлено и 1 удалено
  1. 1 1
      apps/beeswax/src/beeswax/server/hive_server2_lib.py

+ 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
     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))
 
       session = self.open_session(self.user)