svn commit: r1058033 - in /hive/trunk: CHANGES.txt ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java

[he...@apache.org]

Author: heyongqiang
Date: Wed Jan 12 09:36:54 2011
New Revision: 1058033

URL: http://svn.apache.org/viewvc?rev=1058033&view=rev
Log:
HIVE-1907 Store jobid in ExecDriver (namit via He Yongqiang)

Modified:
    hive/trunk/CHANGES.txt
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java

Modified: hive/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hive/trunk/CHANGES.txt?rev=1058033&r1=1058032&r2=1058033&view=diff
==============================================================================
--- hive/trunk/CHANGES.txt (original)
+++ hive/trunk/CHANGES.txt Wed Jan 12 09:36:54 2011
@@ -335,6 +335,9 @@ Trunk -  Unreleased
     confusing it with a release
     (Carl Steinbach via jvs)
 
+    HIVE-1907 Store jobid in ExecDriver
+    (namit via He Yongqiang)
+
   OPTIMIZATIONS
 
   BUG FIXES

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java?rev=1058033&r1=1058032&r2=1058033&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java Wed Jan 12 09:36:54 2011
@@ -104,6 +104,16 @@ public class ExecDriver extends Task<Map
   protected transient JobConf job;
   protected transient int mapProgress = 0;
   protected transient int reduceProgress = 0;
+  public transient String jobId;
+
+  public String getJobId() {
+    return jobId;
+  }
+
+  public void setJobId(String jobId) {
+    this.jobId = jobId;
+  }
+
   public static MemoryMXBean memoryMXBean;
 
   /**
@@ -646,6 +656,8 @@ public class ExecDriver extends Task<Map
       // Finally SUBMIT the JOB!
       rj = jc.submitJob(job);
 
+      jobId = rj.getJobID();
+
       // replace it back
       if (pwd != null) {
         HiveConf.setVar(job, HiveConf.ConfVars.METASTOREPWD, pwd);