diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/self/SeatunnelEngineTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/self/SeatunnelEngineTask.java index f870dfdcd9b7..55acbd656978 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/self/SeatunnelEngineTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/self/SeatunnelEngineTask.java @@ -46,7 +46,7 @@ public void init() { public List buildOptions() throws Exception { List args = super.buildOptions(); if (!Objects.isNull(seatunnelParameters.getDeployMode())) { - args.add(Constants.DEPLOY_MODE_OPTIONS); + args.add(Constants.MASTER_OPTIONS); args.add(seatunnelParameters.getDeployMode().getCommand()); } if (StringUtils.isNotBlank(seatunnelParameters.getOthers())) {