From df9aa418b8aa23ed4ef7d4eb64363f370dc94a46 Mon Sep 17 00:00:00 2001
From: Yhr-N <83159544+Yhr-N@users.noreply.github.com>
Date: Tue, 19 Sep 2023 13:23:27 +0800
Subject: [PATCH] [Fix-14546] seatunnel unable submit spark job to spark
 (#14617)

---
 .../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 8389220a0f..953690b220 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
@@ -56,9 +56,10 @@ public class SeatunnelSparkTask extends SeatunnelTask {
         MasterTypeEnum master = DeployModeEnum.local == seatunnelParameters.getDeployMode() ? MasterTypeEnum.LOCAL : 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;