Index: ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (revision 1153966) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (working copy) @@ -483,6 +483,7 @@ rj.killJob(); } HadoopJobExecHelper.runningJobKillURIs.remove(rj.getJobID()); + jobID = rj.getID().toString(); } } catch (Exception e) { } Index: ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java (revision 1153966) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java (working copy) @@ -59,6 +59,7 @@ protected transient HashMap taskCounters; protected transient DriverContext driverContext; protected transient boolean clonedConf = false; + protected transient String jobID; protected Task backupTask; protected List> backupChildrenTasks = new ArrayList>(); protected static transient Log LOG = LogFactory.getLog(Task.class); @@ -493,4 +494,8 @@ public void setQueryPlan(QueryPlan queryPlan) { this.queryPlan = queryPlan; } + + public String getJobID() { + return jobID; + } } Index: ql/src/java/org/apache/hadoop/hive/ql/io/rcfile/merge/BlockMergeTask.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/io/rcfile/merge/BlockMergeTask.java (revision 1153966) +++ ql/src/java/org/apache/hadoop/hive/ql/io/rcfile/merge/BlockMergeTask.java (working copy) @@ -227,6 +227,7 @@ rj.killJob(); } HadoopJobExecHelper.runningJobKillURIs.remove(rj.getJobID()); + jobID = rj.getID().toString(); } RCFileMergeMapper.jobClose(outputPath, success, job, console); } catch (Exception e) {