(incubator-streampark) branch dev-2.1.3 updated: [Hotfix] fix bug： can`t upload a jar package to hdfs on streampark application type (#3479)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 0734dcef3 [Hotfix] fix bug： can`t upload a jar package to hdfs on 
streampark application type (#3479)
0734dcef3 is described below

commit 0734dcef34a0075685107f9f4d33d720e6bb2663
Author: dsanww <32561607+dsa...@users.noreply.github.com>
AuthorDate: Wed Jan 10 20:45:11 2024 +0800

    [Hotfix] fix bug： can`t upload a jar package to hdfs on streampark 
application type (#3479)
    
    * Update AppBuildPipeServiceImpl.java
    
    * Update Application.java
---
 .../java/org/apache/streampark/console/core/entity/Application.java    | 3 ++-
 .../streampark/console/core/service/impl/AppBuildPipeServiceImpl.java  | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
index e375d521a..4b03ee57b 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Application.java
@@ -465,7 +465,8 @@ public class Application implements Serializable {
   @JsonIgnore
   public boolean isApacheFlinkCustomCodeJob() {
     return DevelopmentMode.CUSTOM_CODE.getValue().equals(this.getJobType())
-        && getApplicationType() == ApplicationType.APACHE_FLINK;
+        && (getApplicationType() == ApplicationType.APACHE_FLINK
+            || getApplicationType() == ApplicationType.STREAMPARK_FLINK);
   }
 
   @JsonIgnore
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 f17995c14..a002a8585 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
@@ -486,7 +486,7 @@ public class AppBuildPipeServiceImpl
 
   private File getAppDistJar(Application app) {
     if (app.getApplicationType() == ApplicationType.STREAMPARK_FLINK) {
-      return new File(app.getDistHome(), app.getModule().concat(".jar"));
+      return new File(app.getDistHome() + "/lib", 
app.getModule().concat(".jar"));
     }
     if (app.getApplicationType() == ApplicationType.APACHE_FLINK) {
       return new File(app.getDistHome(), app.getJar());