diff --git 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 index fbb707ee9b99e35a263a0011bef36c3c4df3b929..c0145b5988287c2d927e049f17a67a34ee2bb685 100644 --- 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 {