diff --git hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordObjectInspectorFactory.java hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordObjectInspectorFactory.java index 18bf3a4058..cb22dead00 100644 --- hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordObjectInspectorFactory.java +++ hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordObjectInspectorFactory.java @@ -19,8 +19,8 @@ package org.apache.hive.hcatalog.data; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; +import java.util.concurrent.ConcurrentHashMap; import org.apache.hadoop.hive.serde2.SerDeException; import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector; @@ -41,10 +41,10 @@ private final static Logger LOG = LoggerFactory.getLogger(HCatRecordObjectInspectorFactory.class); - static HashMap cachedHCatRecordObjectInspectors = - new HashMap(); - static HashMap cachedObjectInspectors = - new HashMap(); + private static final Map + cachedHCatRecordObjectInspectors = new ConcurrentHashMap<>(); + private static final Map + cachedObjectInspectors = new ConcurrentHashMap<>(); /** * Returns HCatRecordObjectInspector given a StructTypeInfo type definition for the record to look into