This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new ca6872a fix：Depend check bug (#2229)
ca6872a is described below
commit ca6872a9a7f51f22142786a3f1c1418e4eb8b99b
Author: Rubik-W <[email protected]>
AuthorDate: Fri Mar 20 21:27:52 2020 +0800
fix：Depend check bug (#2229)
* fix：#1787
* fix：#1787
---
.../dolphinscheduler/server/master/runner/MasterExecThread.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
index 26457a3..3ef7959 100644
---
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
+++
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
@@ -674,9 +674,9 @@ public class MasterExecThread implements Runnable {
TaskNode taskNode = dag.getNode(taskName);
List<String> depNameList = taskNode.getDepList();
for(String depsNode : depNameList ){
-
- if(forbiddenTaskList.containsKey(depsNode) ||
- skipTaskNodeList.containsKey(depsNode)){
+ if(!dag.containsNode(depsNode)
+ || forbiddenTaskList.containsKey(depsNode)
+ || skipTaskNodeList.containsKey(depsNode)){
continue;
}
// dependencies must be fully completed
