From 00008515c0b2734285ed918ee5b3ec9a90659923 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E6=B8=94?= Date: Tue, 27 Feb 2024 15:11:11 +0800 Subject: [PATCH] Update SeatunnelTask.java (#15621) Co-authored-by: Rick Cheng Co-authored-by: xiangzihao <460888207@qq.com> --- .../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;