Index: ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (revision 1178979) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (working copy) @@ -45,12 +45,12 @@ import org.apache.hadoop.hive.ql.stats.ClientStatsPublisher; import org.apache.hadoop.hive.shims.ShimLoader; import org.apache.hadoop.mapred.Counters; +import org.apache.hadoop.mapred.Counters.Counter; import org.apache.hadoop.mapred.JobClient; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.RunningJob; import org.apache.hadoop.mapred.TaskCompletionEvent; import org.apache.hadoop.mapred.TaskReport; -import org.apache.hadoop.mapred.Counters.Counter; import org.apache.log4j.Appender; import org.apache.log4j.BasicConfigurator; import org.apache.log4j.FileAppender; @@ -313,6 +313,14 @@ updateCounters(ctrs, rj); + //Prepare data for Client Stat Publishers (if any present) and execute them + if (clientStatPublishers.size() > 0){ + Map exctractedCounters = extractAllCounterValues(ctrs); + for(ClientStatsPublisher clientStatPublisher : clientStatPublishers){ + clientStatPublisher.run(exctractedCounters, rj.getID().toString()); + } + } + String report = " " + getId() + " map = " + mapProgress + "%, reduce = " + reduceProgress + "%"; @@ -371,14 +379,6 @@ } } - //Prepare data for Client Stat Publishers (if any present) and execute them - if (clientStatPublishers.size() > 0){ - Map exctractedCounters = extractAllCounterValues(ctrs); - for(ClientStatsPublisher clientStatPublisher : clientStatPublishers){ - clientStatPublisher.run(exctractedCounters, rj.getID().toString()); - } - } - Counter counterCpuMsec = ctrs.findCounter("org.apache.hadoop.mapred.Task$Counter", "CPU_MILLISECONDS"); if (counterCpuMsec != null) {