Browse Source

[Fix-11376][task plugin]Seatunnel Task cannot save successfully when … (#11377)

3.1.0-release
Assert 2 years ago committed by GitHub
parent
commit
03582f2e70
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 12
      dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java

12
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 {

Loading…
Cancel
Save