Make RealmEntityManagerFactory thread-safe (apache#532)

geico-sandbox · Dec 11, 2024 · 3dad7d8 · 3dad7d8
1 parent b9d16eb
commit 3dad7d8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ice/common/src/main/java/org/apache/polaris/service/config/RealmEntityManagerFactory.java b/...ice/common/src/main/java/org/apache/polaris/service/config/RealmEntityManagerFactory.java
@@ -20,8 +20,8 @@
 
 import jakarta.inject.Inject;
 import jakarta.inject.Provider;
-import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import org.apache.polaris.core.context.RealmContext;
 import org.apache.polaris.core.persistence.MetaStoreManagerFactory;
 import org.apache.polaris.core.persistence.PolarisEntityManager;
@@ -35,7 +35,7 @@ public class RealmEntityManagerFactory {
   private final MetaStoreManagerFactory metaStoreManagerFactory;
 
   // Key: realmIdentifier
-  private final Map<String, PolarisEntityManager> cachedEntityManagers = new HashMap<>();
+  private final Map<String, PolarisEntityManager> cachedEntityManagers = new ConcurrentHashMap<>();
   private final Provider<EntityCache> entityCache;
 
   // Subclasses for test injection.