diff --git ql/src/java/org/apache/hadoop/hive/ql/QueryDisplay.java ql/src/java/org/apache/hadoop/hive/ql/QueryDisplay.java index 1aa5be3..0dafb00 100644 --- ql/src/java/org/apache/hadoop/hive/ql/QueryDisplay.java +++ ql/src/java/org/apache/hadoop/hive/ql/QueryDisplay.java @@ -23,7 +23,6 @@ import org.apache.hadoop.hive.ql.plan.api.StageType; import java.io.IOException; -import java.io.Serializable; import java.util.*; import org.apache.hadoop.mapred.Counters; @@ -54,7 +53,7 @@ private final LinkedHashMap tasks = new LinkedHashMap(); - public void updateTaskStatus(Task tTask) { + public synchronized void updateTaskStatus(Task tTask) { if (!tasks.containsKey(tTask.getId())) { tasks.put(tTask.getId(), new TaskDisplay(tTask)); } @@ -374,11 +373,11 @@ this.queryId = queryId; } - private String returnStringOrUnknown(String s) { + private static String returnStringOrUnknown(String s) { return s == null ? "UNKNOWN" : s; } - public long getQueryStartTime() { + public synchronized long getQueryStartTime() { return queryStartTime; } }