diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java index e8a1757..8870049 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java @@ -400,10 +400,6 @@ private TezClient startSessionAndContainers(TezClient session, HiveConf conf, // TezSessionPoolManager sets tez.queue.name if user has specified one or use the one from // cluster wide queue names. // There is no way to differentiate how this was set (user vs system). - // Unset this after opening the session so that reopening of session uses the correct queue - // names i.e, if client has not died and if the user has explicitly set a queue name - // then reopened session will use user specified queue name else default cluster queue names. - conf.unset(TezConfiguration.TEZ_QUEUE_NAME); return session; } finally { if (isOnThread && !isSuccessful) {