diff --git ql/src/java/org/apache/hadoop/hive/ql/log/HIVE-11149.03.patch ql/src/java/org/apache/hadoop/hive/ql/log/HIVE-11149.03.patch new file mode 100644 index 0000000..e69de29 diff --git ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java index 20ca195..6c56af0 100644 --- ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java +++ ql/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java @@ -106,7 +106,8 @@ public static PerfLogger getPerfLogger(boolean resetPerfLogger) { } return perfLogger.get(); } else { - return SessionState.get().getPerfLogger(resetPerfLogger); + perfLogger.set(SessionState.get().getPerfLogger(resetPerfLogger)); + return perfLogger.get(); } } @@ -155,7 +156,7 @@ public long PerfLogEnd(String callerName, String method) { * @param _log */ public void close(Log _log, QueryPlan queryPlan) { - + perfLogger.remove(); } public Long getStartTime(String method) {