From 79b05a440573e401f22aafa3f233f1626248b02b Mon Sep 17 00:00:00 2001 From: lenboo Date: Fri, 14 Jun 2019 16:58:48 +0800 Subject: [PATCH] change forbidden task process --- .../main/java/cn/escheduler/dao/utils/DagHelper.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 58267f78db..c101d2791c 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 @@ -250,10 +250,10 @@ public class DagHelper { startVertexs = dag.getBeginNode(); } - Collection tmpStartVertexs = new ArrayList<>(); + List tmpStartVertexs = new ArrayList<>(); tmpStartVertexs.addAll(startVertexs); - for(String start : tmpStartVertexs){ + for(String start : startVertexs){ TaskNode startNode = dag.getNode(start); if(!startNode.isForbidden()){ continue; @@ -262,13 +262,13 @@ public class DagHelper { for(String post : postNodes){ if(checkForbiddenPostCanSubmit(post, dag)){ - startVertexs.add(post); + tmpStartVertexs.add(post); } } - startVertexs.remove(start); + tmpStartVertexs.remove(start); } - return startVertexs; + return tmpStartVertexs; } /**