You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ki...@apache.org on 2020/12/13 04:17:55 UTC
[incubator-dolphinscheduler] branch dev updated: fix bug: start
from the setting nodes with NODE_PRE would be NPE. (#4219)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new b694474 fix bug: start from the setting nodes with NODE_PRE would be NPE. (#4219)
b694474 is described below
commit b694474c78cafb298dd41d03cc0c54d2179dde2a
Author: bao liang <29...@users.noreply.github.com>
AuthorDate: Sun Dec 13 12:17:43 2020 +0800
fix bug: start from the setting nodes with NODE_PRE would be NPE. (#4219)
---
.../src/main/java/org/apache/dolphinscheduler/dao/utils/DagHelper.java | 3 +++
1 file changed, 3 insertions(+)
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 9a77232..6ee1c19 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
@@ -398,6 +398,9 @@ public class DagHelper {
DAG<String, TaskNode, TaskNodeRelation> dag,
Map<String, TaskInstance> completeTaskList,
Map<String, TaskNode> skipTaskNodeList) {
+ if (!dag.containsNode(skipNodeName)) {
+ return;
+ }
skipTaskNodeList.putIfAbsent(skipNodeName, dag.getNode(skipNodeName));
Collection<String> postNodeList = dag.getSubsequentNodes(skipNodeName);
for (String post : postNodeList) {