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 f1a7f46..0ec8f54 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 @@ -494,7 +494,7 @@ private void printDagSummary(Map progressMap, LogHelper consol if (progress != null) { final int totalTasks = progress.getTotalTaskCount(); final int failedTaskAttempts = progress.getFailedTaskAttemptCount(); - final int killedTasks = progress.getKilledTaskCount(); + final int killedTaskAttempts = progress.getKilledTaskAttemptCount(); final double duration = perfLogger.getDuration(PerfLogger.TEZ_RUN_VERTEX + vertexName) / 1000.0; VertexStatus vertexStatus = null; @@ -581,7 +581,7 @@ private void printDagSummary(Map progressMap, LogHelper consol vertexName, totalTasks, failedTaskAttempts, - killedTasks, + killedTaskAttempts, secondsFormat.format((duration)), commaFormat.format(cpuTimeMillis), commaFormat.format(gcTimeMillis), @@ -621,7 +621,7 @@ private void printStatusInPlace(Map progressMap, long startTim final int failed = progress.getFailedTaskAttemptCount(); final int pending = progress.getTotalTaskCount() - progress.getSucceededTaskCount() - progress.getRunningTaskCount(); - final int killed = progress.getKilledTaskCount(); + final int killed = progress.getKilledTaskAttemptCount(); // To get vertex status we can use DAGClient.getVertexStatus(), but it will be expensive to // get status from AM for every refresh of the UI. Lets infer the state from task counts.