diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/TableScanOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/TableScanOperator.java index cb010fb..b8818b8 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/TableScanOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/TableScanOperator.java @@ -68,6 +68,8 @@ private String defaultPartitionName; + private String taskId; + public TableDesc getTableDesc() { return tableDesc; } @@ -196,6 +198,9 @@ protected void initializeOp(Configuration hconf) throws HiveException { if (conf == null) { return; } + + taskId = Utilities.getTaskId(hconf); + rowLimit = conf.getRowLimit(); if (!conf.isGatherStats()) { return; @@ -286,7 +291,7 @@ private void publishStats() throws HiveException { return; } - String taskID = Utilities.getTaskIdFromFilename(Utilities.getTaskId(hconf)); + String taskID = Utilities.getTaskIdFromFilename(taskId); Map statsToPublish = new HashMap(); for (String pspecs : stats.keySet()) {