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 29f6bfa..ec71c72 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 @@ -113,6 +113,7 @@ public int monitorExecution(final DAGClient dagClient, HiveTxnManager txnMgr, String lastReport = null; Set opts = new HashSet(); Heartbeater heartbeater = new Heartbeater(txnMgr, conf); + long startTime = 0; shutdownList.add(dagClient); @@ -145,6 +146,7 @@ public int monitorExecution(final DAGClient dagClient, HiveTxnManager txnMgr, for (String s: progressMap.keySet()) { perfLogger.PerfLogBegin(CLASS_NAME, PerfLogger.TEZ_RUN_VERTEX + s); } + startTime = System.currentTimeMillis(); running = true; } @@ -152,7 +154,8 @@ public int monitorExecution(final DAGClient dagClient, HiveTxnManager txnMgr, 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;