diff --git ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java index e2f3ea5..7e80c2d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java +++ ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistory.java @@ -409,6 +409,9 @@ public class HiveHistory { public void printRowCount(String queryId) { QueryInfo ji = queryInfoMap.get(queryId); + if (ji == null) { + return; + } for (String tab : ji.rowCountMap.keySet()) { console.printInfo(ji.rowCountMap.get(tab) + " Rows loaded to " + tab); } @@ -420,7 +423,6 @@ public class HiveHistory { * @param queryId */ public void endQuery(String queryId) { - QueryInfo ji = queryInfoMap.get(queryId); if (ji == null) { return;