You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/12/04 10:31:17 UTC
(iotdb) 06/07: Enhance procedure recover policy
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch rc/2.0.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 53e20c10284709e7fc5efb8ef88c05f0f53680b7
Author: Potato <ta...@apache.org>
AuthorDate: Mon Dec 2 14:09:09 2024 +0800
Enhance procedure recover policy
---
.../java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
index 4cf768027c6..b84daf9f045 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
@@ -127,8 +127,8 @@ public class ProcedureExecutor<Env> {
if (!proc.hasParent()) {
rollbackStack.put(proc.getProcId(), new RootProcedureStack<>());
}
+ procedures.putIfAbsent(proc.getProcId(), proc);
}
- procedures.putIfAbsent(proc.getProcId(), proc);
}
List<Procedure<Env>> runnableList = new ArrayList<>();
List<Procedure<Env>> failedList = new ArrayList<>();