From 0734dcef34a0075685107f9f4d33d720e6bb2663 Mon Sep 17 00:00:00 2001
From: dsanww <32561607+dsanww@users.noreply.github.com>
Date: Wed, 10 Jan 2024 20:45:11 +0800
Subject: [PATCH] =?UTF-8?q?[Hotfix]=20fix=20bug=EF=BC=9A=20can`t=20upload?=
 =?UTF-8?q?=20a=20jar=20package=20to=20hdfs=20on=20streampark=20applicatio?=
 =?UTF-8?q?n=20type=20(#3479)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

* Update AppBuildPipeServiceImpl.java

* Update Application.java
---
 .../org/apache/streampark/console/core/entity/Application.java | 3 ++-
 .../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 e375d521ae..4b03ee57b5 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 boolean isCustomCodeJob() {
   @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 f17995c144..a002a85850 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 @@ private void prepareJars(Application app) throws IOException {
 
   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());