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 20ca195..9abb469 100644 --- ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java +++ ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java @@ -23,6 +23,7 @@ import org.apache.hadoop.hive.ql.QueryPlan; import org.apache.hadoop.hive.ql.session.SessionState; +import java.util.Collections; import java.util.HashMap; import java.util.Map; @@ -79,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 = Collections.synchronizedMap(new HashMap()); + protected final Map endTimes = Collections.synchronizedMap(new HashMap()); static final private Log LOG = LogFactory.getLog(PerfLogger.class.getName());