diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java b/escheduler-dao/src/main/java/cn/escheduler/dao/utils/DagHelper.java index c101d2791c..d811cf78bc 100644 --- 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 tmpStartVertexs = new ArrayList<>(); - tmpStartVertexs.addAll(startVertexs); + if(startVertexs!= null){ + tmpStartVertexs.addAll(startVertexs); + } for(String start : startVertexs){ TaskNode startNode = dag.getNode(start);