Index: ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (revision 1057503) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (working copy) @@ -104,6 +104,16 @@ 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 @@ // Finally SUBMIT the JOB! rj = jc.submitJob(job); + jobId = rj.getJobID(); + // replace it back if (pwd != null) { HiveConf.setVar(job, HiveConf.ConfVars.METASTOREPWD, pwd);