[Improve] rename checkJarFile method in Utils.scala (#3422)
diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala
index 4666747..7f3953e 100644
--- a/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala
+++ b/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala
@@ -129,7 +129,7 @@
if (ext.isEmpty) {
addURL(file)
} else if (ext.exists(x => file.getName.endsWith(x))) {
- Utils.checkJarFile(file.toURI.toURL)
+ Utils.requireCheckJarFile(file.toURI.toURL)
addURL(file)
}
}
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
index e5bc051..be09b29 100644
--- 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
@@ -73,7 +73,7 @@
def uuid(): String = UUID.randomUUID().toString.replaceAll("-", "")
@throws[IOException]
- def checkJarFile(jar: URL): Unit = {
+ def requireCheckJarFile(jar: URL): Unit = {
val jarFile: File = Try(new File(jar.toURI)) match {
case Success(x) => x
case Failure(_) => throw new IOException(s"JAR file path is invalid $jar")
@@ -92,7 +92,7 @@
}
def getJarManifest(jarFile: File): jar.Manifest = {
- checkJarFile(jarFile.toURL)
+ requireCheckJarFile(jarFile.toURL)
new JarInputStream(new BufferedInputStream(new FileInputStream(jarFile))).getManifest
}
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
index 3d178ac..6059143 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/ApplicationController.java
@@ -361,7 +361,7 @@
public RestResponse checkjar(String jar) {
File file = new File(jar);
try {
- Utils.checkJarFile(file.toURI().toURL());
+ Utils.requireCheckJarFile(file.toURI().toURL());
return RestResponse.success(true);
} catch (IOException e) {
return RestResponse.success(file).message(e.getLocalizedMessage());
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java
index b860f49..45c950e 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/ProjectBuildTask.java
@@ -181,7 +181,7 @@
}
} else {
// 2) .jar file(normal or official standard flink project)
- Utils.checkJarFile(app.toURI().toURL());
+ Utils.requireCheckJarFile(app.toURI().toURL());
String moduleName = app.getName().replace(Constant.JAR_SUFFIX, "");
File distHome = project.getDistHome();
File targetDir = new File(distHome, moduleName);
diff --git a/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala b/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala
index bd46481..c424b3b 100644
--- a/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala
+++ b/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/maven/MavenTool.scala
@@ -82,7 +82,7 @@
}
private val isJarFile = (file: File) =>
- file.isFile && Try(Utils.checkJarFile(file.toURI.toURL)).isSuccess
+ file.isFile && Try(Utils.requireCheckJarFile(file.toURI.toURL)).isSuccess
/**
* Build a fat-jar with custom jar libraries.
