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..aa348dc 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,7 @@ public static SessionState start(SessionState startSs) { if (startSs.tezSessionState == null) { startSs.tezSessionState = new TezSessionState(startSs.getSessionId()); } - startSs.tezSessionState.open(startSs.conf); + // will be opened in TezTask if needed } catch (Exception e) { throw new RuntimeException(e); }