[Fix] Upload Flink App jar got "flink app jar must exist" error on wi…

…ndows (#4052) (#4053) * fix Upload Flink App jar got "flink app jar must exist" error on windows
apache · Oct 3, 2024 · cee932b · cee932b
1 parent d435746
commit cee932b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...ark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java b/...ark-console-service/src/main/java/org/apache/streampark/console/core/entity/Resource.java
@@ -83,7 +83,7 @@ public void setResourcePath(String resourcePath) {
         if (StringUtils.isBlank(resourcePath)) {
             throw new IllegalArgumentException("resource path cannot be null.");
         }
-        String[] namePath = resourcePath.split(":");
+        String[] namePath = resourcePath.split(":", 2);
         if (namePath.length != 2) {
             throw new IllegalArgumentException("resource path invalid, format: $name:$path");
         }
@@ -101,6 +101,6 @@ public String getFilePath() {
         if (StringUtils.isBlank(this.resourcePath)) {
             return null;
         }
-        return resourcePath.split(":")[1];
+        return resourcePath.split(":", 2)[1];
     }
 }
diff --git a/...ce/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java b/...ce/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
@@ -153,7 +153,7 @@ public void addResource(Resource resource) throws Exception {
             String resourcePath = jars.get(0);
             resource.setResourcePath(resourcePath);
             // copy jar to team upload directory
-            String upFile = resourcePath.split(":")[1];
+            String upFile = resourcePath.split(":", 2)[1];
             transferTeamResource(resource.getTeamId(), upFile);
         }
 
@@ -207,7 +207,7 @@ public void updateResource(Resource resource) {
 
             Dependency dependency = Dependency.toDependency(resource.getResource());
             if (!dependency.getJar().isEmpty()) {
-                String jarFile = dependency.getJar().get(0).split(":")[1];
+                String jarFile = dependency.getJar().get(0).split(":", 2)[1];
                 transferTeamResource(findResource.getTeamId(), jarFile);
             }
         }
@@ -446,7 +446,7 @@ private File getResourceJar(Resource resource) throws Exception {
             return null;
         }
         if (!dependency.getJar().isEmpty()) {
-            String jar = dependency.getJar().get(0).split(":")[1];
+            String jar = dependency.getJar().get(0).split(":", 2)[1];
             return new File(jar);
         } else {
             Artifact artifact = dependency.toArtifact().get(0);