commit 7a1ea84c2869519e6838edcd6a20b2a614c3aca6 Author: Bharath Krishna Date: Thu Mar 22 11:14:16 2018 -0700 HIVE-18928 : Fixing the race condition in Perflogger diff --git common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java index 764a832e28114c977fb5cd2c0191e944500d7394..a0eecb3d03718daf4188504f9454728042eef533 100644 --- common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java +++ common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java @@ -30,6 +30,7 @@ import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; /** * PerfLogger. @@ -86,8 +87,8 @@ public static final String SPARK_OPTIMIZE_TASK_TREE = "SparkOptimizeTaskTree"; public static final String SPARK_FLUSH_HASHTABLE = "SparkFlushHashTable."; - protected final Map startTimes = new HashMap(); - protected final Map endTimes = new HashMap(); + protected final Map startTimes = new ConcurrentHashMap(); + protected final Map endTimes = new ConcurrentHashMap(); static final private Logger LOG = LoggerFactory.getLogger(PerfLogger.class.getName()); protected static final ThreadLocal perfLogger = new ThreadLocal();