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 27f0216a1e..262bbb9a0b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -607,10 +607,8 @@ public static void endStart(SessionState startSs) private static void start(SessionState startSs, boolean isAsync, LogHelper console) { setCurrentSessionState(startSs); - synchronized(SessionState.class) { - if (!startSs.isStarted.compareAndSet(false, true)) { - return; - } + if (!startSs.isStarted.compareAndSet(false, true)) { + return; } if (startSs.hiveHist == null){