HIVE-27029: hive query fails with Filesystem closed error, Rework don…

…e for HIVE-26352 (Mahesh Raju Somalaraju, reviewed by Laszlo Vegh)
yeahyung · Jul 20, 2023 · 9fa5e8f · 9fa5e8f
1 parent 9886398
commit 9fa5e8f
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/YarnQueueHelper.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/YarnQueueHelper.java
@@ -94,19 +94,15 @@ public YarnQueueHelper(HiveConf conf) {
   }
 
   public void checkQueueAccess(
-      String queueName, String userName) throws IOException, InterruptedException {
+      String queueName, String userName) throws IOException {
     UserGroupInformation ugi = UserGroupInformation.getCurrentUser();
     try {
       ugi.doAs((PrivilegedExceptionAction<Void>) () -> {
         checkQueueAccessInternal(queueName, userName);
         return null;
       });
-    } finally {
-      try {
-        FileSystem.closeAllForUGI(ugi);
-      } catch (IOException exception) {
-        LOG.error("Could not clean up file-system handles for UGI: " + ugi, exception);
-      }
+    } catch (Exception exception) {
+      LOG.error("Cannot check queue access against UGI: " + ugi, exception);
     }
   }