diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java index 9eb95a1..2afad7b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -418,11 +418,7 @@ protected void initializeOp(Configuration hconf) throws HiveException { numRows = 0; - String context = jc.get(Operator.CONTEXT_NAME_KEY, ""); - if (context != null && !context.isEmpty()) { - context = "_" + context.replace(" ","_"); - } - statsMap.put(Counter.RECORDS_OUT + context, row_count); + statsMap.put(Counter.RECORDS_OUT + "_" + conf.getDestTableId() + "_" + conf.getTableInfo().getTableName().toLowerCase(), row_count); initializeChildren(hconf); } catch (HiveException e) { diff --git ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryImpl.java ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryImpl.java index f75b70e..b7c4238 100644 --- ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryImpl.java +++ ql/src/java/org/apache/hadoop/hive/ql/history/HiveHistoryImpl.java @@ -67,7 +67,7 @@ private static final String DELIMITER = " "; - private static final String ROW_COUNT_PATTERN = "TABLE_ID_(\\d+)_ROWCOUNT"; + private static final String ROW_COUNT_PATTERN = "RECORDS_OUT_(\\d+)_(\\S+)"; private static final Pattern rowCountPattern = Pattern.compile(ROW_COUNT_PATTERN); @@ -343,6 +343,10 @@ String getRowCountTableName(String name) { if (m.find()) { String tuple = m.group(1); + String tableName = m.group(2); + if (tableName != null) + return tableName; + return idToTableMap.get(tuple); } return null;