(incubator-streampark) branch perjob updated: [Improve] minor improvement

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch perjob
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/perjob by this push:
     new 5db235656 [Improve] minor improvement
5db235656 is described below

commit 5db2356564a3fcda4ec3befa3187e6acc91905aa
Author: benjobs <benj...@gmail.com>
AuthorDate: Sat Nov 18 00:16:04 2023 +0800

    [Improve] minor improvement
---
 .../console/core/service/impl/AppBuildPipeServiceImpl.java | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
index cc733e84e..12443d2ce 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
@@ -468,16 +468,14 @@ public class AppBuildPipeServiceImpl
   }
 
   private File getAppDistJar(Application app) {
-    File userJar;
     if (app.getApplicationType() == ApplicationType.STREAMPARK_FLINK) {
-      userJar = new File(app.getDistHome(), app.getModule().concat(".jar"));
-    } else if (app.getApplicationType() == ApplicationType.APACHE_FLINK) {
-      userJar = new File(app.getDistHome(), app.getJar());
-    } else {
-      throw new IllegalArgumentException(
-          "[StreamPark] unsupported ApplicationType of custom code: " + 
app.getApplicationType());
+      return new File(app.getDistHome(), app.getModule().concat(".jar"));
+    }
+    if (app.getApplicationType() == ApplicationType.APACHE_FLINK) {
+      return new File(app.getDistHome(), app.getJar());
     }
-    return userJar;
+    throw new IllegalArgumentException(
+        "[StreamPark] unsupported ApplicationType of custom code: " + 
app.getApplicationType());
   }
 
   /** copy from {@link ApplicationServiceImpl#start(Application, boolean)} */