HIVE-10845: TezJobMonitor uses killedTaskCount instead of killedTaskAttemptCount (Sid Seth via Gunther Hagleitner)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e22aaf63 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e22aaf63 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e22aaf63 Branch: refs/heads/spark Commit: e22aaf6381a607a39bb238e5376ca3928790fc08 Parents: b6b638a Author: Gunther Hagleitner <gunt...@apache.org> Authored: Mon Jun 1 17:05:27 2015 -0700 Committer: Gunther Hagleitner <gunt...@apache.org> Committed: Mon Jun 1 17:05:27 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/e22aaf63/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java index 4423cd1..78caba8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java @@ -496,7 +496,7 @@ public class TezJobMonitor { 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; @@ -583,7 +583,7 @@ public class TezJobMonitor { vertexName, totalTasks, failedTaskAttempts, - killedTasks, + killedTaskAttempts, secondsFormat.format((duration)), commaFormat.format(cpuTimeMillis), commaFormat.format(gcTimeMillis), @@ -623,7 +623,7 @@ public class TezJobMonitor { 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.
