|
|
@ -43,13 +43,12 @@ public class SeatunnelFlinkTask extends SeatunnelTask { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public List<String> buildOptions() throws Exception { |
|
|
|
public List<String> buildOptions() throws Exception { |
|
|
|
List<String> args = super.buildOptions(); |
|
|
|
List<String> args = super.buildOptions(); |
|
|
|
if (!(Objects.isNull(seatunnelParameters.getRunMode()) |
|
|
|
|
|
|
|
&& SeatunnelFlinkParameters.RunModeEnum.NONE.equals(seatunnelParameters.getRunMode()))) { |
|
|
|
if (Objects.nonNull(seatunnelParameters.getRunMode()) |
|
|
|
args.add( |
|
|
|
&& !SeatunnelFlinkParameters.RunModeEnum.NONE.equals(seatunnelParameters.getRunMode())) { |
|
|
|
Objects.isNull(seatunnelParameters.getRunMode()) |
|
|
|
args.add(seatunnelParameters.getRunMode().getCommand()); |
|
|
|
? SeatunnelFlinkParameters.RunModeEnum.RUN.getCommand() |
|
|
|
|
|
|
|
: seatunnelParameters.getRunMode().getCommand()); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (StringUtils.isNotBlank(seatunnelParameters.getOthers())) { |
|
|
|
if (StringUtils.isNotBlank(seatunnelParameters.getOthers())) { |
|
|
|
args.add(seatunnelParameters.getOthers()); |
|
|
|
args.add(seatunnelParameters.getOthers()); |
|
|
|
} |
|
|
|
} |
|
|
|