You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2015/06/06 01:16:35 UTC
[22/50] [abbrv] hive git commit: HIVE-10845: TezJobMonitor uses
killedTaskCount instead of killedTaskAttemptCount (Sid Seth via Gunther
Hagleitner)
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/hbase-metastore
Commit: e22aaf6381a607a39bb238e5376ca3928790fc08
Parents: b6b638a
Author: Gunther Hagleitner <gu...@apache.org>
Authored: Mon Jun 1 17:05:27 2015 -0700
Committer: Gunther Hagleitner <gu...@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.