Code optimization

apache · May 27, 2024 · 05105b2 · 05105b2
1 parent 27449c3
commit 05105b2
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala
@@ -16,6 +16,8 @@
  */
 package org.apache.streampark.common.util
 
+import org.apache.streampark.common.util.ImplicitsUtils.AutoCloseImplicits
+
 import org.apache.commons.lang3.StringUtils
 
 import java.io._
@@ -71,14 +73,8 @@ object Utils extends Logger {
 
   def getJarManifest(jarFile: File): jar.Manifest = {
     requireCheckJarFile(jarFile.toURL)
-    var jarInputStream: JarInputStream = null;
-    try {
-      jarInputStream = new JarInputStream(new BufferedInputStream(new FileInputStream(jarFile)))
-      jarInputStream.getManifest
-    } finally {
-      if (jarInputStream != null)
-        jarInputStream.close
-    }
+    new JarInputStream(new BufferedInputStream(new FileInputStream(jarFile)))
+      .autoClose(_.getManifest)
   }
 
   def getJarManClass(jarFile: File): String = {