diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index 1c84c6aa27..3238cb284e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -141,6 +141,12 @@ public int execute(DriverContext driverContext) { // Need to remove this static hack. But this is the way currently to get a session. SessionState ss = SessionState.get(); session = ss.getTezSession(); + + if (session != null && (session.getQueueName() == null) && conf.get(TezConfiguration.TEZ_QUEUE_NAME) != null) { + session.close(false); + session = null; + } + if (session != null && !session.isOpen()) { LOG.warn("The session: " + session + " has not been opened"); }