You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by nz...@apache.org on 2011/09/16 17:32:19 UTC
svn commit: r1171626 - in /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql:
MapRedStats.java exec/HadoopJobExecHelper.java
Author: nzhang
Date: Fri Sep 16 15:32:19 2011
New Revision: 1171626
URL: http://svn.apache.org/viewvc?rev=1171626&view=rev
Log:
HIVE-2447. Add job ID to MapRedStats (Kevin Wilfong via Ning Zhang)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java?rev=1171626&r1=1171625&r2=1171626&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/MapRedStats.java Fri Sep 16 15:32:19 2011
@@ -39,11 +39,14 @@ public class MapRedStats {
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 @@ public class MapRedStats {
this.success = success;
}
+ public String getJobId() {
+ return jobId;
+ }
+
+ public void setJobId(String jobId) {
+ this.jobId = jobId;
+ }
+
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java?rev=1171626&r1=1171625&r2=1171626&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java Fri Sep 16 15:32:19 2011
@@ -372,7 +372,7 @@ public class HadoopJobExecHelper {
}
}
- MapRedStats mapRedStats = new MapRedStats(numMap, numReduce, cpuMsec, success);
+ MapRedStats mapRedStats = new MapRedStats(numMap, numReduce, cpuMsec, success, rj.getID().toString());
Counter ctr;