From f375be7a6384911bde070a7c3ed2ebe1ac06ad80 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E5=BC=A0?= <60912722+boy-xiaozhang@users.noreply.github.com> Date: Sat, 6 Nov 2021 19:27:00 +0800 Subject: [PATCH] [FIX:201106]fix issue#6657 (#6717) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: 张柏强 --- .../java/org/apache/dolphinscheduler/dao/utils/DagHelper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 e692645dae..bf96edd4c7 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 @@ -106,7 +106,7 @@ public class DagHelper { } else { // specified start nodes or resume execution for (String startNodeCode : startNodeList) { - TaskNode startNode = findNodeByCode(taskNodeList, startNodeCode); + TaskNode startNode = findNodeByName(taskNodeList, startNodeCode); List childNodeList = new ArrayList<>(); if (startNode == null) { logger.error("start node name [{}] is not in task node list [{}] ",