diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java index d90eacf..9391ad7 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java @@ -63,7 +63,7 @@ public TezJobMonitor() { * @return int 0 - success, 1 - killed, 2 - failed */ public int monitorExecution(DAGClient dagClient) throws InterruptedException { - DAGStatus status; + DAGStatus status = null; boolean running = false; boolean done = false; @@ -146,6 +146,11 @@ public int monitorExecution(DAGClient dagClient) throws InterruptedException { } if (done) { + if (rc != 0 && status != null) { + for (String diag: status.getDiagnostics()) { + console.printError(diag); + } + } break; } Thread.sleep(500);