diff --git common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java index 6263a6d..67b2282 100644 --- common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java +++ common/src/java/org/apache/hadoop/hive/ql/log/PerfLogger.java @@ -84,7 +84,7 @@ protected static final ThreadLocal perfLogger = new ThreadLocal(); - public PerfLogger() { + private PerfLogger() { // Use getPerfLogger to get an instance of PerfLogger } diff --git ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index 014941e..aa1603b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -214,8 +214,6 @@ */ LineageState ls; - private PerfLogger perfLogger; - private final String userName; /** @@ -1547,12 +1545,8 @@ public static PerfLogger getPerfLogger(boolean resetPerfLogger) { SessionState ss = get(); if (ss == null) { return PerfLogger.getPerfLogger(null, resetPerfLogger); - } else if (ss.perfLogger != null && !resetPerfLogger) { - return ss.perfLogger; } else { - PerfLogger perfLogger = PerfLogger.getPerfLogger(ss.getConf(), resetPerfLogger); - ss.perfLogger = perfLogger; - return perfLogger; + return PerfLogger.getPerfLogger(ss.getConf(), resetPerfLogger); } }