diff --git a/service/src/java/org/apache/hive/service/server/ThreadFactoryWithGarbageCleanup.java b/service/src/java/org/apache/hive/service/server/ThreadFactoryWithGarbageCleanup.java index ec19abc..fb8141a 100644 --- a/service/src/java/org/apache/hive/service/server/ThreadFactoryWithGarbageCleanup.java +++ b/service/src/java/org/apache/hive/service/server/ThreadFactoryWithGarbageCleanup.java @@ -19,8 +19,8 @@ package org.apache.hive.service.server; -import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ThreadFactory; import org.apache.hadoop.hive.metastore.RawStore; @@ -43,7 +43,7 @@ */ public class ThreadFactoryWithGarbageCleanup implements ThreadFactory { - private static Map threadRawStoreMap = new HashMap(); + private static Map threadRawStoreMap = new ConcurrentHashMap(); private final String namePrefix;