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

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 00008515c0 Update SeatunnelTask.java (#15621)
00008515c0 is described below

commit 00008515c0b2734285ed918ee5b3ec9a90659923
Author: 王渔 <cqwan...@2016.cqut.edu.cn>
AuthorDate: Tue Feb 27 15:11:11 2024 +0800

    Update SeatunnelTask.java (#15621)
    
    Co-authored-by: Rick Cheng <rickche...@gmail.com>
    Co-authored-by: xiangzihao <460888...@qq.com>
---
 .../apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
index b6d0b6136e..547e0158ef 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTask.java
@@ -162,7 +162,7 @@ public class SeatunnelTask extends AbstractRemoteTask {
                 args.add(CONFIG_OPTIONS);
                 // TODO: Need further check for refactored resource center
                 // TODO Currently resourceName is `/xxx.sh`, it has more `/` 
and needs to be optimized
-                args.add(resourceInfo.getResourceName().substring(1));
+                args.add(resourceInfo.getResourceName().replaceFirst(".*:", 
""));
             });
         }
         return args;

Reply via email to