|
@@ -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
|