diff --git ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryUtil.java ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryUtil.java index a7ca165..c7cf2a3 100644 --- ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryUtil.java +++ ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryUtil.java @@ -70,9 +70,6 @@ public static void parseHiveHistory(String path, Listener l) throws IOException private static final Pattern pattern = Pattern.compile(KEY + "=" + "\"" + VALUE + "\""); - // temp buffer for parsed dataa - private static Map parseBuffer = new HashMap(); - /** * Parse a single line of history. * @@ -81,6 +78,8 @@ public static void parseHiveHistory(String path, Listener l) throws IOException * @throws IOException */ private static void parseLine(String line, Listener l) throws IOException { + Map parseBuffer = new HashMap(); + // extract the record type int idx = line.indexOf(' '); String recType = line.substring(0, idx); @@ -96,8 +95,5 @@ private static void parseLine(String line, Listener l) throws IOException { } l.handle(RecordTypes.valueOf(recType), parseBuffer); - - parseBuffer.clear(); } - }