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

[Bug] [Seatunnel-Task] Run Mode defaults to run, and you cannot select a null value (#14267) 

Co-authored-by: zhang <zhangyfcoder@163.com>
(cherry picked from commit 4111acb58e)
This commit is contained in:
zyfjrx 2023-07-12 09:06:19 +08:00 committed by Jay Chung
parent d414f2631b
commit c0b2b1c0e3
3 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkParameters.java
View File

@ -35,6 +35,7 @@ public class SeatunnelFlinkParameters extends SeatunnelParameters {
@Getter
public enum RunModeEnum {
NONE("none"),
RUN("--run-mode run"),
RUN_APPLICATION("--run-mode run-application");

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

@ -44,9 +44,13 @@ public class SeatunnelFlinkTask extends SeatunnelTask {
@Override
public List<String> buildOptions() throws Exception {
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())) {
args.add(seatunnelParameters.getOthers());
}

4
dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-sea-tunnel.ts
View File

@ -196,6 +196,10 @@ export const STARTUP_SCRIPT = [
]
export const FLINK_RUN_MODE = [
{
label: 'none',
value: 'NONE'
},
{
label: 'run',
value: 'RUN'