close resouce in catch block

apache · Mar 2, 2021 · 0f3e509 · 0f3e509
1 parent 1f1a1ef
commit 0f3e509
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...op-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/EditLogFileOutputStream.java b/...op-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/EditLogFileOutputStream.java
@@ -88,7 +88,12 @@ public EditLogFileOutputStream(Configuration conf, File name, int size)
     } else {
       rp = new RandomAccessFile(name, "rw");
     }
-    fp = new FileOutputStream(rp.getFD()); // open for append
+    try {
+      fp = new FileOutputStream(rp.getFD()); // open for append
+    } catch (IOException e) {
+      IOUtils.closeStream(rp);
+      throw e;
+    }
     fc = rp.getChannel();
     fc.position(fc.size());
   }