diff --git llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java index ff91f474dd..2637871849 100644 --- llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java +++ llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java @@ -31,6 +31,7 @@ import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; +import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Random; @@ -345,8 +346,11 @@ public static void close(String handleId) throws IOException { */ public static void closeAll() { LOG.debug("Closing all handles"); - for (String handleId : connectionMap.keySet()) { + Iterator handleIds = connectionMap.keySet().iterator(); + String handleId = null; + while (handleIds.hasNext()) { try { + handleId = handleIds.next(); close(handleId); } catch (Exception err) { LOG.error("Error closing handle ID " + handleId, err);