From 556a19c0ab2a6b82fb2ff15ee8e10f6bb9a490aa Mon Sep 17 00:00:00 2001 From: zeyu10 Date: Tue, 15 Oct 2024 10:13:45 +0800 Subject: [PATCH] modify comments --- .../weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java b/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java index 9a90d8d88..7d57b20a7 100644 --- a/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java +++ b/rill-flow-dag/olympicene-core/src/main/java/com/weibo/rill/flow/olympicene/core/helper/DAGWalkHelper.java @@ -161,7 +161,7 @@ private boolean isDependenciesAllSuccessOrSkip(TaskInfo taskInfo, boolean hasStr /** * 判断依赖的所有任务是否都已完成 * 1. 如果没有依赖，说明依赖的所有任务都已完成 - * 2. 如果依赖的是 Stream 输入类型的节点，那么忽略该 Stream 输入节点，检查 Stream 输入节点的所有依赖是否都已完成 + * 2. 如果依赖的是 Stream 输入类型的节点，那么忽略该 Stream 输入节点，递归检查 Stream 输入节点的所有依赖是否都已完成 * 3. 如果依赖的是非 Stream 输入类型的节点，那么检查该非 Stream 输入节点是否已完成 * * @param taskInfo 待处理的任务信息