|
|
@ -43,7 +43,13 @@ 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(); |
|
|
|
args.add(Objects.isNull(seatunnelParameters.getRunMode()) ? SeatunnelFlinkParameters.RunModeEnum.RUN.getCommand() : seatunnelParameters.getRunMode().getCommand()); |
|
|
|
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 (StringUtils.isNotBlank(seatunnelParameters.getOthers())) { |
|
|
|
if (StringUtils.isNotBlank(seatunnelParameters.getOthers())) { |
|
|
|
args.add(seatunnelParameters.getOthers()); |
|
|
|
args.add(seatunnelParameters.getOthers()); |
|
|
|
} |
|
|
|
} |
|
|
|