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 <[email protected]> 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<>();
