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..b0f2586 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -416,13 +416,8 @@ protected void initializeOp(Configuration hconf) throws HiveException { bucketInspector = (IntObjectInspector)bucketField.getFieldObjectInspector(); } - 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); + row_count.set(numRows); + statsMap.put(Counter.RECORDS_OUT + "_" + conf.getDestTableId(), 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..aa7f48d 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+)"; private static final Pattern rowCountPattern = Pattern.compile(ROW_COUNT_PATTERN);