[dolphinscheduler] branch dev updated: [Fix-14546] seatunnel unable submit spark job to spark (#14617)

[kerwin]

This is an automated email from the ASF dual-hosted git repository.

kerwin 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 9083f9d0e0 [Fix-14546] seatunnel unable submit spark job to spark 
(#14617)
9083f9d0e0 is described below

commit 9083f9d0e0be6dab488b049aaa51f3f447edc272
Author: Yhr-N <83159544+yh...@users.noreply.github.com>
AuthorDate: Tue Sep 19 13:23:27 2023 +0800

    [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 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;