Enhance procedure recover policy

OneSizeFitsQuorum · web-flow · commit 496c62e18192 · 2024-12-02T14:09:09.000+08:00
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
@@ -127,8 +127,8 @@ private void recover() {
         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<>();

Original file line number	Diff line number	Diff line change
`@@ -127,8 +127,8 @@ private void recover() {`
`127`	`127`	`if (!proc.hasParent()) {`
`128`	`128`	`rollbackStack.put(proc.getProcId(), new RootProcedureStack<>());`
`129`	`129`	`}`
	`130`	`+ procedures.putIfAbsent(proc.getProcId(), proc);`
`130`	`131`	`}`
`131`		`- procedures.putIfAbsent(proc.getProcId(), proc);`
`132`	`132`	`}`
`133`	`133`	`List<Procedure<Env>> runnableList = new ArrayList<>();`
`134`	`134`	`List<Procedure<Env>> failedList = new ArrayList<>();`