From 5756d6b02910d139f00b4b412078f32c5ca14c54 Mon Sep 17 00:00:00 2001 From: bao liang <29528966+lenboo@users.noreply.github.com> Date: Thu, 13 Aug 2020 19:02:14 +0800 Subject: [PATCH] fix bug: Fix master task dependency check bug (#3473) Co-authored-by: lenboo --- .../server/master/runner/MasterExecThread.java | 4 +--- 1 file changed, 1 insertion(+), 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 6692598ce6..15cc814b26 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 @@ -667,12 +667,10 @@ public class MasterExecThread implements Runnable { List depNameList = taskNode.getDepList(); for(String depsNode : depNameList ){ if(!dag.containsNode(depsNode) + || skipTaskNodeList.containsKey(depsNode) || forbiddenTaskList.containsKey(depsNode)){ continue; } - if(skipTaskNodeList.containsKey(depsNode)){ - return DependResult.FAILED; - } // all the dependencies must be completed if(!completeTaskList.containsKey(depsNode)){ return DependResult.WAITING;