diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java index bd5d888a69..9a772322e8 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java @@ -276,7 +276,7 @@ public class DagHelper { } for (String dependNodeName : dependList) { TaskNode dependNode = dag.getNode(dependNodeName); - if (completeTaskList.containsKey(dependNodeName) + if (dependNode == null || completeTaskList.containsKey(dependNodeName) || dependNode.isForbidden() || skipTaskNodeList.containsKey(dependNodeName)) { continue;