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

[cherry-pick][Fix-7019][MasterServer] Fix the issue with failing to save and run the process that contains the switch task (#7068) 

* [Fix-7019][MasterServer] Fix the issue with failing to save and run the process that contains the switch task. (#7046)

* fix switch next code

Co-authored-by: Hua Jiang <jianghuachinacom@163.com>
Co-authored-by: caishunfeng <534328519@qq.com>
This commit is contained in:
wind 2021-11-30 16:40:39 +08:00 committed by GitHub
parent 77f4b0aaf5
commit 26d2c52c25
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/switchtask/SwitchParameters.java
View File

@ -29,6 +29,8 @@ public class SwitchParameters extends AbstractParameters {
private DependentRelation dependRelation;
private String relation;
private List<String> nextNode;
private int resultConditionLocation;
private List<SwitchResultVo> dependTaskList;
@Override
public boolean checkParameters() {
@ -40,9 +42,6 @@ public class SwitchParameters extends AbstractParameters {
return new ArrayList<>();
}
private int resultConditionLocation;
private List<SwitchResultVo> dependTaskList;
public DependentRelation getDependRelation() {
return dependRelation;
}
@ -84,6 +83,10 @@ public class SwitchParameters extends AbstractParameters {
List<String> nextNodeList = new ArrayList<>();
nextNodeList.add(String.valueOf(nextNode));
this.nextNode = nextNodeList;
} else if (nextNode instanceof Number) {
List<String> nextNodeList = new ArrayList<>();
nextNodeList.add(nextNode.toString());
this.nextNode = nextNodeList;
} else {
this.nextNode = (ArrayList) nextNode;
}