[dolphinscheduler] branch dev updated: [Fix-11376][task plugin]Seatunnel Task cannot save successfully when … (#11377)

[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 03582f2e70 [Fix-11376][task plugin]Seatunnel Task cannot save 
successfully when … (#11377)
03582f2e70 is described below

commit 03582f2e7039498d5563626b88dd8616d163c3f3
Author: Assert <42203474+shange...@users.noreply.github.com>
AuthorDate: Wed Aug 10 12:54:09 2022 +0800

    [Fix-11376][task plugin]Seatunnel Task cannot save successfully when … 
(#11377)
---
 .../task/seatunnel/spark/SeatunnelSparkParameters.java       | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java
index 1cc5285f39..a21538e9b5 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java
@@ -33,10 +33,14 @@ public class SeatunnelSparkParameters extends 
SeatunnelParameters {
 
     @Override
     public boolean checkParameters() {
-        return super.checkParameters()
-                && Objects.nonNull(deployMode)
-                && (DeployModeEnum.local != deployMode && 
Objects.nonNull(master))
-                && (DeployModeEnum.local != deployMode && 
(MasterTypeEnum.SPARK == master || MasterTypeEnum.MESOS == master) && 
StringUtils.isNotBlank(masterUrl));
+        boolean result = super.checkParameters() && 
Objects.nonNull(deployMode);
+        if (result && DeployModeEnum.local != deployMode) {
+            result = Objects.nonNull(master);
+            if (result && (MasterTypeEnum.SPARK == master || 
MasterTypeEnum.MESOS == master)) {
+                result = StringUtils.isNotBlank(masterUrl);
+            }
+        }
+        return result;
     }
 
     public static enum MasterTypeEnum {