diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index 4ff1596..c6f431c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -114,7 +114,8 @@ public int execute(DriverContext driverContext) { // if we don't have one yet create it. if (session == null) { - ss.setTezSession(new TezSessionState()); + session = new TezSessionState(); + ss.setTezSession(session); } // if it's not running start it.