natas_hw
/
dolphinscheduler0701
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix wrong judgment condition when building parameters of seatunnel task node. (#14594)

This commit is contained in:
Kerwin 2023-07-20 12:26:10 +08:00 committed by zhuangchong
parent 64537405b7
commit 10157e1c69
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
View File

@ -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());
}