svn commit: r1627423 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java

[gunther]

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;