(incubator-streampark) branch dev updated: fix update job upload jar and build failed (#4091)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 54c725aee fix update job upload jar and build failed (#4091)
54c725aee is described below

commit 54c725aeeb3f5976e9cdc12fb4ef160ce726d8b4
Author: Xie Yi <105206850+xieyi...@users.noreply.github.com>
AuthorDate: Tue Dec 3 12:11:31 2024 +0800

    fix update job upload jar and build failed (#4091)
    
    Co-authored-by: xieyi01 <xiey...@rd.netease.com>
---
 .../application/impl/FlinkApplicationBuildPipelineServiceImpl.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
index db30f140e..fc9958cb2 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java
@@ -254,6 +254,10 @@ public class FlinkApplicationBuildPipelineServiceImpl
                                 if (resource != null && 
StringUtils.isNotBlank(resource.getFilePath())) {
                                     localJar = new 
File(resource.getFilePath());
                                     uploadJar = 
appUploads.concat("/").concat(localJar.getName());
+                                } else {
+                                    localJar =
+                                        new File(WebUtils.getAppTempDir(), 
app.getJar());
+                                    uploadJar = 
appUploads.concat("/").concat(localJar.getName());
                                 }
                             }
                             // upload jar copy to appHome