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 342f219..375ee1f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -352,7 +352,9 @@ public static SessionState start(SessionState startSs) { if (startSs.tezSessionState == null) { startSs.tezSessionState = new TezSessionState(startSs.getSessionId()); } - startSs.tezSessionState.open(startSs.conf); + if (!startSs.tezSessionState.isOpen()) { + startSs.tezSessionState.open(startSs.conf); // use conf on session start up + } } catch (Exception e) { throw new RuntimeException(e); }