Index: ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (revision 1179456) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (working copy) @@ -312,6 +312,14 @@ errMsg.setLength(0); updateCounters(ctrs, rj); + + //Prepare data for Client Stat Publishers (if any present) and execute them + if (clientStatPublishers.size() > 0 && ctrs != null){ + Map exctractedCounters = extractAllCounterValues(ctrs); + for(ClientStatsPublisher clientStatPublisher : clientStatPublishers){ + clientStatPublisher.run(exctractedCounters, rj.getID().toString()); + } + } String report = " " + getId() + " map = " + mapProgress + "%, reduce = " + reduceProgress + "%"; @@ -373,14 +381,6 @@ } } - //Prepare data for Client Stat Publishers (if any present) and execute them - if (clientStatPublishers.size() > 0 && ctrs != null){ - Map exctractedCounters = extractAllCounterValues(ctrs); - for(ClientStatsPublisher clientStatPublisher : clientStatPublishers){ - clientStatPublisher.run(exctractedCounters, rj.getID().toString()); - } - } - if (ctrs != null) { Counter counterCpuMsec = ctrs.findCounter("org.apache.hadoop.mapred.Task$Counter", "CPU_MILLISECONDS");