Index: ql/src/java/org/apache/hadoop/hive/ql/exec/mr/JobDebugger.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/JobDebugger.java (revision c8ed87720749a3b37dc7381ba820f451b7394936) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/JobDebugger.java (revision befa5d569f174c66caeb2b6bbfc0d2118b6dcca3) @@ -34,6 +34,7 @@ import org.apache.hadoop.hive.ql.ErrorMsg; import org.apache.hadoop.hive.ql.exec.errors.ErrorAndSolution; import org.apache.hadoop.hive.ql.exec.errors.TaskLogProcessor; +import org.apache.hadoop.hive.ql.session.OperationLog; import org.apache.hadoop.hive.ql.session.SessionState.LogHelper; import org.apache.hadoop.hive.shims.ShimLoader; import org.apache.hadoop.mapred.JobConf; @@ -55,6 +56,8 @@ private final Map taskIdToInfo = new HashMap(); private int maxFailures = 0; + private OperationLog operationLog; + // Used for showJobFailDebugInfo private static class TaskInfo { String jobId; @@ -115,12 +118,18 @@ public void run() { try { + OperationLog.setCurrentOperationLog(operationLog); showJobFailDebugInfo(); + OperationLog.removeCurrentOperationLog(); } catch (IOException e) { console.printError(e.getMessage()); } } + public void setCurrentOperationLog(OperationLog operationLog){ + this.operationLog = operationLog; + } + public static int extractErrorCode(String[] diagnostics) { int result = 0; Pattern errorCodeRegex = ErrorMsg.getErrorCodePattern(); Index: ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java (revision c8ed87720749a3b37dc7381ba820f451b7394936) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/HadoopJobExecHelper.java (revision befa5d569f174c66caeb2b6bbfc0d2118b6dcca3) @@ -46,6 +46,7 @@ import org.apache.hadoop.hive.ql.history.HiveHistory.Keys; import org.apache.hadoop.hive.ql.lockmgr.HiveTxnManager; import org.apache.hadoop.hive.ql.plan.ReducerTimeStatsPerJob; +import org.apache.hadoop.hive.ql.session.OperationLog; import org.apache.hadoop.hive.ql.session.SessionState; import org.apache.hadoop.hive.ql.session.SessionState.LogHelper; import org.apache.hadoop.hive.ql.stats.ClientStatsPublisher; @@ -577,6 +578,8 @@ } else { jd = new JobDebugger(job, rj, console); } + OperationLog operationLog = OperationLog.getCurrentOperationLog(); + jd.setCurrentOperationLog(operationLog); Thread t = new Thread(jd); t.start(); t.join(HiveConf.getIntVar(job, HiveConf.ConfVars.JOB_DEBUG_TIMEOUT));