You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2014/09/24 23:22:07 UTC
svn commit: r1627423 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
Author: gunther
Date: Wed Sep 24 21:22:07 2014
New Revision: 1627423
URL: http://svn.apache.org/r1627423
Log:
HIVE-8210: TezJobMonitor should print time spent in Application (RUNNING) (Gopal V via Gunther Hagleitner)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java?rev=1627423&r1=1627422&r2=1627423&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java Wed Sep 24 21:22:07 2014
@@ -113,6 +113,7 @@ public class TezJobMonitor {
String lastReport = null;
Set<StatusGetOpts> opts = new HashSet<StatusGetOpts>();
Heartbeater heartbeater = new Heartbeater(txnMgr, conf);
+ long startTime = 0;
shutdownList.add(dagClient);
@@ -145,6 +146,7 @@ public class TezJobMonitor {
for (String s: progressMap.keySet()) {
perfLogger.PerfLogBegin(CLASS_NAME, PerfLogger.TEZ_RUN_VERTEX + s);
}
+ startTime = System.currentTimeMillis();
running = true;
}
@@ -152,7 +154,8 @@ public class TezJobMonitor {
break;
case SUCCEEDED:
lastReport = printStatus(progressMap, lastReport, console);
- console.printInfo("Status: Finished successfully");
+ double duration = (System.currentTimeMillis() - startTime)/1000.0;
+ console.printInfo("Status: Finished successfully in " + String.format("%.2f seconds", duration));
running = false;
done = true;
break;