Procedure: Fix ProcedureInfo on CN leader may decrease its procId (#1…

…2711)
apache · Jun 11, 2024 · ed3b4b7 · ed3b4b7
1 parent e887ea0
commit ed3b4b7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ProcedureInfo.java b/...-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ProcedureInfo.java
@@ -135,7 +135,7 @@ public void upgrade() {
   public TSStatus updateProcedure(UpdateProcedurePlan updateProcedurePlan) {
     Procedure<ConfigNodeProcedureEnv> procedure = updateProcedurePlan.getProcedure();
     procedureMap.put(procedure.getProcId(), procedure);
-    lastProcId.set(Math.max(lastProcId.get(), procedure.getProcId()));
+    lastProcId.updateAndGet(id -> Math.max(id, procedure.getProcId()));
     return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
   }