Bladeren bron

[editor] Close past multi queries

Romain Rigaux 10 jaren geleden
bovenliggende
commit
1eaf4026c3
1 gewijzigde bestanden met toevoegingen van 5 en 0 verwijderingen
  1. 5 0
      desktop/libs/notebook/src/notebook/connectors/hiveserver2.py

+ 5 - 0
desktop/libs/notebook/src/notebook/connectors/hiveserver2.py

@@ -79,6 +79,11 @@ class HS2Api(Api):
     # Multiquery, if not first statement or arrived to the last query
     # Multiquery, if not first statement or arrived to the last query
     statement_id = snippet['result']['handle'].get('statement_id', 0)
     statement_id = snippet['result']['handle'].get('statement_id', 0)
     if snippet['result']['handle'].get('has_more'):
     if snippet['result']['handle'].get('has_more'):
+      try:
+        handle = self._get_handle(snippet)
+        db.close_operation(handle) # Close all the time past multi queries
+      except:
+        LOG.warn('Could not close previous multiquery query')
       statement_id += 1
       statement_id += 1
     else:
     else:
       statement_id = 0
       statement_id = 0