[dolphinscheduler] branch 3.2.0-prepare updated: Fix wrong judgment condition when building parameters of seatunnel task node. (#14594)

[kerwin]

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

kerwin pushed a commit to branch 3.2.0-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/3.2.0-prepare by this push:
     new 10157e1c69 Fix wrong judgment condition when building parameters of 
seatunnel task node. (#14594)
10157e1c69 is described below

commit 10157e1c6913488fbf18d314798e91e4481f765c
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Thu Jul 20 12:26:10 2023 +0800

    Fix wrong judgment condition when building parameters of seatunnel task 
node. (#14594)
---
 .../plugin/task/seatunnel/flink/SeatunnelFlinkTask.java       | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
index 32d5fa3e05..7918c6d183 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
@@ -44,13 +44,12 @@ public class SeatunnelFlinkTask extends SeatunnelTask {
     @Override
     public List<String> buildOptions() throws Exception {
         List<String> args = super.buildOptions();
-        if (!(Objects.isNull(seatunnelParameters.getRunMode())
-                && 
SeatunnelFlinkParameters.RunModeEnum.NONE.equals(seatunnelParameters.getRunMode())))
 {
-            args.add(
-                    Objects.isNull(seatunnelParameters.getRunMode())
-                            ? 
SeatunnelFlinkParameters.RunModeEnum.RUN.getCommand()
-                            : seatunnelParameters.getRunMode().getCommand());
+
+        if (Objects.nonNull(seatunnelParameters.getRunMode())
+                && 
!SeatunnelFlinkParameters.RunModeEnum.NONE.equals(seatunnelParameters.getRunMode()))
 {
+            args.add(seatunnelParameters.getRunMode().getCommand());
         }
+
         if (StringUtils.isNotBlank(seatunnelParameters.getOthers())) {
             args.add(seatunnelParameters.getOthers());
         }