From 1037cbf10fd09f7d34c5c12d9c8af0d79ca70bf5 Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Tue, 7 Jul 2026 09:31:05 +0800
Subject: [PATCH] Fix RegionGroupCache activation race

---
 .../manager/load/cache/region/RegionGroupCache.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupCache.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupCache.java
index e441054b1dfb6..2cdecc757fd26 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupCache.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupCache.java
@@ -66,7 +66,7 @@ public RegionGroupCache(
    * @param newHeartbeatSample The newest RegionHeartbeatSample
    * @param overwrite Able to overwrite Adding or Removing
    */
-  public void cacheHeartbeatSample(
+  public synchronized void cacheHeartbeatSample(
       int dataNodeId, RegionHeartbeatSample newHeartbeatSample, boolean overwrite) {
     // Only cache sample when the corresponding loadCache exists
     Optional.ofNullable(regionCacheMap.get(dataNodeId))
@@ -83,7 +83,7 @@ public void cacheHeartbeatSample(int dataNodeId, RegionHeartbeatSample newHeartb
    *
    * @param dataNodeId the specified DataNode
    */
-  public void createRegionCache(int dataNodeId, TConsensusGroupId groupId) {
+  public synchronized void createRegionCache(int dataNodeId, TConsensusGroupId groupId) {
     regionCacheMap.put(dataNodeId, new RegionCache(dataNodeId, groupId));
   }
 
@@ -92,7 +92,7 @@ public void createRegionCache(int dataNodeId, TConsensusGroupId groupId) {
    *
    * @param dataNodeId the specified DataNode
    */
-  public void removeRegionCache(int dataNodeId) {
+  public synchronized void removeRegionCache(int dataNodeId) {
     regionCacheMap.remove(dataNodeId);
   }
 
@@ -100,7 +100,7 @@ public void removeRegionCache(int dataNodeId) {
    * Update currentStatistics based on the latest NodeHeartbeatSamples that cached in the
    * slidingWindow.
    */
-  public void updateCurrentStatistics() {
+  public synchronized void updateCurrentStatistics() {
     regionCacheMap.values().forEach(regionCache -> regionCache.updateCurrentStatistics(false));
     Map<Integer, RegionStatistics> regionStatisticsMap =
         regionCacheMap.entrySet().stream()