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;