diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/RenderStrategy.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/RenderStrategy.java index 2535b10..478efc4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/RenderStrategy.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/RenderStrategy.java @@ -78,8 +78,9 @@ private String getReport(Map progressMap) { if (!perfLogger.startTimeHasMethod(PerfLogger.TEZ_RUN_VERTEX + s)) { perfLogger.PerfLogBegin(TezJobMonitor.CLASS_NAME, PerfLogger.TEZ_RUN_VERTEX + s); } - - perfLogger.PerfLogEnd(TezJobMonitor.CLASS_NAME, PerfLogger.TEZ_RUN_VERTEX + s); + if (perfLogger.getEndTime(PerfLogger.TEZ_RUN_VERTEX + s) <= 0) { + perfLogger.PerfLogEnd(TezJobMonitor.CLASS_NAME, PerfLogger.TEZ_RUN_VERTEX + s); + } } if (complete < total && (complete > 0 || running > 0 || failed > 0)) {