Index: ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java (revision 1075265) +++ ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java (working copy) @@ -425,6 +425,7 @@ return; } log(RecordTypes.QueryEnd, ji.hm); + queryInfoMap.remove(queryId); } /** @@ -465,6 +466,7 @@ return; } log(RecordTypes.TaskEnd, ti.hm); + taskInfoMap.remove(id); } /**