retain closeQuietly feature

apache · Aug 31, 2021 · 17810db · 17810db
1 parent 737c7f3
commit 17810db
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/...azure/src/main/java/org/apache/hadoop/fs/azurebfs/utils/TextFileBasedIdentityHandler.java b/...azure/src/main/java/org/apache/hadoop/fs/azurebfs/utils/TextFileBasedIdentityHandler.java
@@ -172,7 +172,9 @@ private static void loadMap(HashMap<String, String> cache, String fileLocation,
     LOG.debug("Loading identity map from file {}", fileLocation);
     int errorRecord = 0;
     File file = new File(fileLocation);
-    try (LineIterator it = FileUtils.lineIterator(file, "UTF-8")) {
+    LineIterator it = null;
+    try {
+      it = FileUtils.lineIterator(file, "UTF-8");
       while (it.hasNext()) {
         String line = it.nextLine();
         if (!Strings.isNullOrEmpty(line.trim()) && !line.startsWith(HASH)) {
@@ -186,6 +188,14 @@ private static void loadMap(HashMap<String, String> cache, String fileLocation,
       LOG.debug("Loaded map stats - File: {}, Loaded: {}, Error: {} ", fileLocation, cache.size(), errorRecord);
     } catch (ArrayIndexOutOfBoundsException e) {
       LOG.error("Error while parsing mapping file", e);
+    } finally {
+      try {
+        if (it != null) {
+          it.close();
+        }
+      } catch (IOException ioe) {
+        LOG.error("IOException thrown on LineIterator close");
+      }
     }
   }
 }