Index: ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java (revision 900da82915209630ec7c194619028e5fa1b87d28) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java (date 1516354904000) @@ -2127,7 +2127,13 @@ PoolState poolState = pools.get(poolName); if (poolState != null) { poolState.getSessions().remove(toKill); - poolState.getInitializingSessions().remove(toKill); + Iterator iter = poolState.getInitializingSessions().iterator(); + while (iter.hasNext()) { + if (iter.next().session.equals(toKill)) { + iter.remove(); + break; + } + } } }