diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ParentQueue.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ParentQueue.java index de92c9c..d07b224 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ParentQueue.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ParentQueue.java @@ -158,7 +158,7 @@ synchronized void setupQueueConfigs(Resource clusterResource, float capacity, } private static float PRECISION = 0.0005f; // 0.05% precision - void setChildQueues(Collection childQueues) { + synchronized void setChildQueues(Collection childQueues) { // Validate float childCapacities = 0; for (CSQueue queue : childQueues) { @@ -715,7 +715,7 @@ public ActiveUsersManager getActiveUsersManager() { } @Override - public void collectSchedulerApplications( + public synchronized void collectSchedulerApplications( Collection apps) { for (CSQueue queue : childQueues) { queue.collectSchedulerApplications(apps);