diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolManager.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolManager.java index b70dbd8..78817de 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolManager.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionPoolManager.java @@ -480,7 +480,7 @@ protected TezSessionPoolSession createSession(String sessionId) { */ private static boolean canWorkWithSameSession(TezSessionState session, HiveConf conf) throws HiveException { - if (session == null || conf == null) { + if (session == null || conf == null || !session.isOpen()) { return false; }