This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 3.2.0-release in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 87d6092ef9567da14bb51b90790c292933da7c83 Author: Yhr-N <[email protected]> AuthorDate: Tue Sep 19 13:23:27 2023 +0800 [Fix-14546] seatunnel unable submit spark job to spark (#14617) (cherry picked from commit 9083f9d0e0be6dab488b049aaa51f3f447edc272) --- .../plugin/task/seatunnel/spark/SeatunnelSparkTask.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkTask.java index 9f66d34374..d8b1a69156 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkTask.java @@ -58,9 +58,10 @@ public class SeatunnelSparkTask extends SeatunnelTask { : seatunnelParameters.getMaster(); args.add(MASTER_OPTIONS); - args.add(master.getCommand()); if (MasterTypeEnum.SPARK.equals(master) || MasterTypeEnum.MESOS.equals(master)) { - args.add(seatunnelParameters.getMasterUrl()); + args.add(master.getCommand() + seatunnelParameters.getMasterUrl()); + } else { + args.add(master.getCommand()); } return args;
