Browse Source

[FIX:201106]fix issue#6657 (#6717)

Co-authored-by: 张柏强 <zhangbaiqiang@lvshou.com>
小张 3 years ago
parent
commit
69f2d3b21b

+ 1 - 1
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 [{}] ",