change forbidden task process.

6 years ago · 0865aeca39
1 changed files with 3 additions and 1 deletions
--- a/escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java
+++ b/escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java
@ -251,7 +251,9 @@ public class DagHelper {
        }

        List<String> tmpStartVertexs = new ArrayList<>();
-        tmpStartVertexs.addAll(startVertexs);
+        if(startVertexs!= null){
+            tmpStartVertexs.addAll(startVertexs);
+        }

        for(String start : startVertexs){
            TaskNode startNode = dag.getNode(start);