[FLINK-2538] Close created JarFile in ClassLoaderUtil

5322e870 · Ufuk Celebi · b2f8e307 · 5322e870
显示空白变更内容
内联并排

Showing with 7 addition and 1 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/util/ClassLoaderUtil.java ...n/java/org/apache/flink/runtime/util/ClassLoaderUtil.java +7 -1

未找到文件。
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClassLoaderUtil.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/ClassLoaderUtil.java
@@ -72,13 +72,19 @@ public class ClassLoaderUtil {
 								bld.append(" (directory)");
 							}
 							else {
+								JarFile jar = null;
 								try {
-									new JarFile(filePath);
+									jar = new JarFile(filePath);
 									bld.append(" (valid JAR)");
 								}
 								catch (Exception e) {
 									bld.append(" (invalid JAR: ").append(e.getMessage()).append(')');
 								}
+								finally {
+									if (jar != null) {
+										jar.close();
+									}
+								}
 							}
 						}
 						else {