Browse Source

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

Co-authored-by: 张柏强 <zhangbaiqiang@lvshou.com>
2.0.7-release
小张 3 years ago committed by lenboo
parent
commit
f375be7a63
  1. 2
      dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java

2
dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java

@ -106,7 +106,7 @@ public class DagHelper {
} else { } else {
// specified start nodes or resume execution // specified start nodes or resume execution
for (String startNodeCode : startNodeList) { for (String startNodeCode : startNodeList) {
TaskNode startNode = findNodeByCode(taskNodeList, startNodeCode); TaskNode startNode = findNodeByName(taskNodeList, startNodeCode);
List<TaskNode> childNodeList = new ArrayList<>(); List<TaskNode> childNodeList = new ArrayList<>();
if (startNode == null) { if (startNode == null) {
logger.error("start node name [{}] is not in task node list [{}] ", logger.error("start node name [{}] is not in task node list [{}] ",

Loading…
Cancel
Save