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 bd935d4..d247e83 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 @@ -452,6 +452,7 @@ private void printQueryExecutionBreakDown() { String execBreakdownHeader = String.format(OPERATION_SUMMARY, OPERATION, DURATION); console.printInfo(SEPARATOR); reprintLineWithColorAsBold(execBreakdownHeader, Ansi.Color.CYAN); + console.logInfo(execBreakdownHeader); console.printInfo(SEPARATOR); // parse, analyze, optimize and compile @@ -515,10 +516,12 @@ private void printDagSummary(Map progressMap, LogHelper consol if (inPlaceEligible) { console.printInfo(SEPARATOR); reprintLineWithColorAsBold(SUMMARY_HEADER, Ansi.Color.CYAN); + console.logInfo(SUMMARY_HEADER); console.printInfo(SEPARATOR); } else { console.printInfo(FILE_HEADER_SEPARATOR); reprintLineWithColorAsBold(FILE_HEADER, Ansi.Color.CYAN); + console.logInfo(FILE_HEADER); console.printInfo(FILE_HEADER_SEPARATOR); } SortedSet keys = new TreeSet(progressMap.keySet()); @@ -679,6 +682,7 @@ private void printLlapIOSummary(Map progressMap, LogHelper con if (!first) { console.printInfo(SEPARATOR); reprintLineWithColorAsBold(LLAP_SUMMARY_HEADER, Ansi.Color.CYAN); + console.logInfo(LLAP_SUMMARY_HEADER); console.printInfo(SEPARATOR); first = true; } @@ -712,8 +716,10 @@ private void printFSCountersSummary(Map progressMap, LogHelper console.printInfo(""); reprintLineWithColorAsBold("Scheme: " + scheme, Ansi.Color.RED); + console.logInfo("Scheme: " + scheme); console.printInfo(SEPARATOR); reprintLineWithColorAsBold(fsCountersHeader, Ansi.Color.CYAN); + console.logInfo(fsCountersHeader); console.printInfo(SEPARATOR); for (String vertexName : keys) {