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: 小张 <[email protected]>
AuthorDate: Sat Nov 6 19:27:00 2021 +0800
[FIX:201106]fix issue#6657 (#6717)
Co-authored-by: 张柏强 <[email protected]>
---
.../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 [{}] ",
