YARN-3487. CapacityScheduler scheduler lock obtained unnecessarily when calling getQueue (Jason Lowe via wangda)
(cherry picked from commit f47a5763ac
)
This commit is contained in:
parent
e7cbecddc3
commit
3316cd4357
|
@ -190,6 +190,8 @@ Release 2.7.1 - UNRELEASED
|
|||
OPTIMIZATIONS
|
||||
|
||||
BUG FIXES
|
||||
YARN-3487. CapacityScheduler scheduler lock obtained unnecessarily when
|
||||
calling getQueue (Jason Lowe via wangda)
|
||||
|
||||
YARN-3462. Patches applied for YARN-2424 are inconsistent between
|
||||
trunk and branch-2. (Naganarasimha G R via harsh)
|
||||
|
|
|
@ -642,7 +642,7 @@ public class CapacityScheduler extends
|
|||
return queue;
|
||||
}
|
||||
|
||||
public synchronized CSQueue getQueue(String queueName) {
|
||||
public CSQueue getQueue(String queueName) {
|
||||
if (queueName == null) {
|
||||
return null;
|
||||
}
|
||||
|
@ -940,11 +940,7 @@ public class CapacityScheduler extends
|
|||
boolean includeChildQueues, boolean recursive)
|
||||
throws IOException {
|
||||
CSQueue queue = null;
|
||||
|
||||
synchronized (this) {
|
||||
queue = this.queues.get(queueName);
|
||||
}
|
||||
|
||||
queue = this.queues.get(queueName);
|
||||
if (queue == null) {
|
||||
throw new IOException("Unknown queue: " + queueName);
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue