diff --git ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java index f202991..acdee59 100644 --- ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java +++ ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java @@ -23,7 +23,7 @@ import org.apache.hadoop.hive.ql.QueryPlan; import org.apache.hadoop.hive.ql.session.SessionState; -import java.util.HashMap; +import java.util.concurrent.ConcurrentHashMap; import java.util.Map; /** @@ -80,8 +80,8 @@ protected static final ThreadLocal perfLogger = new ThreadLocal(); - 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 Log LOG = LogFactory.getLog(PerfLogger.class.getName());