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;