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;