(iotdb) branch fix_procedure_recover created (now ece716d2a1c)

[ta...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a change to branch fix_procedure_recover
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at ece716d2a1c fix

This branch includes the following new commits:

     new ece716d2a1c fix

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(iotdb) 01/01: fix

[ta...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch fix_procedure_recover
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit ece716d2a1cd76478e3896cc9a969524dd77946f
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Mon Dec 2 12:30:15 2024 +0800

    fix
    
    Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
 .../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<>();