From bcaa3a52e009219609e03c4617cd531cdcde89bb Mon Sep 17 00:00:00 2001 From: Oleg Danilov Date: Fri, 19 Jan 2018 17:45:19 +0300 Subject: HIVE-18492: Fixed wrong usage of remove(toKill) --- .../java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java index 98505b6eba7..3175b2b514d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WorkloadManager.java @@ -2127,7 +2127,13 @@ private void resetAndQueueKill(Map toKillQuery, 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; + } + } } }