[incubator-streampark] branch dev updated: Fix remote task submission could not find the jar (#2973)

[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 5ee673965 Fix remote task submission could not find the jar (#2973)
5ee673965 is described below

commit 5ee67396596bee51a01acae9f324ceb9b6d75f6a
Author: ChengJie1053 <18033291...@163.com>
AuthorDate: Sun Aug 27 15:47:45 2023 +0800

    Fix remote task submission could not find the jar (#2973)
---
 .../console/core/service/impl/AppBuildPipeServiceImpl.java        | 8 ++++++++
 1 file changed, 8 insertions(+)

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 9adfc0e3e..f9017a724 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
@@ -423,6 +423,14 @@ public class AppBuildPipeServiceImpl
   private BuildPipeline createPipelineInstance(@Nonnull Application app) {
     FlinkEnv flinkEnv = flinkEnvService.getByIdOrDefault(app.getVersionId());
     String flinkUserJar = retrieveFlinkUserJar(flinkEnv, app);
+
+    if (!new File(flinkUserJar).exists()) {
+      Resource resource = resourceService.findByResourceName(app.getTeamId(), 
app.getJar());
+      if (resource != null && StringUtils.isNotBlank(resource.getFilePath())) {
+        flinkUserJar = resource.getFilePath();
+      }
+    }
+
     ExecutionMode executionMode = app.getExecutionModeEnum();
     String mainClass = ConfigConst.STREAMPARK_FLINKSQL_CLIENT_CLASS();
     switch (executionMode) {