Index: ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (revision 1171172) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (working copy) @@ -372,7 +372,7 @@ } } - MapRedStats mapRedStats = new MapRedStats(numMap, numReduce, cpuMsec, success); + MapRedStats mapRedStats = new MapRedStats(numMap, numReduce, cpuMsec, success, rj.getID().toString()); Counter ctr; Index: ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java (revision 1171172) +++ ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java (working copy) @@ -39,11 +39,14 @@ long reduceShuffleBytes = -1; boolean success; - public MapRedStats(int numMap, int numReduce, long cpuMSec, boolean ifSuccess) { + String jobId; + + public MapRedStats(int numMap, int numReduce, long cpuMSec, boolean ifSuccess, String jobId) { this.numMap = numMap; this.numReduce = numReduce; this.cpuMSec = cpuMSec; this.success = ifSuccess; + this.jobId = jobId; } public boolean isSuccess() { @@ -134,6 +137,14 @@ this.success = success; } + public String getJobId() { + return jobId; + } + + public void setJobId(String jobId) { + this.jobId = jobId; + } + @Override public String toString() { StringBuilder sb = new StringBuilder();