[dolphinscheduler] branch dev updated: [FIX:201106]fix issue#6657 (#6717)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 69f2d3b  [FIX:201106]fix issue#6657 (#6717)
69f2d3b is described below

commit 69f2d3b21bc99006fd1fa4e0f0b970972d26ae2f
Author: 小张 <60...@users.noreply.github.com>
AuthorDate: Sat Nov 6 19:27:00 2021 +0800

    [FIX:201106]fix issue#6657 (#6717)
    
    Co-authored-by: 张柏强 <zh...@lvshou.com>
---
 .../src/main/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 e692645..bf96edd 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<TaskNode> childNodeList = new ArrayList<>();
                 if (startNode == null) {
                     logger.error("start node name [{}] is not in task node list [{}] ",