Fix remote task submission could not find the jar (#2973)

apache · Aug 27, 2023 · 5ee6739 · 5ee6739
1 parent 41cdbc3
commit 5ee6739
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java b/...rc/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
@@ -423,6 +423,14 @@ private void checkBuildEnv(Long appId, boolean forceBuild) {
   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) {