diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java index 49d2166..a52d8b1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java @@ -190,7 +190,14 @@ public class FSLeafQueue extends FSQueue { void updateInternal() { readLock.lock(); try { - policy.computeShares(runnableApps, getFairShare()); + double runnableAppsSize = runnableApps.size(); + if (runnableAppsSize != 0){ + long runnableAppShare = (long)Math.ceil((getFairShare().getMemorySize())/runnableAppsSize); + for (FSAppAttempt appSched : runnableApps){ + Resource target = appSched.getFairShare(); + target.setMemorySize(runnableAppShare); + } + } } finally { readLock.unlock(); }