Browse Source

Fixed CS locality wait factor.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/MR-279@1156707 13f79535-47bb-0310-9956-ffa450edef68
Arun Murthy 14 years ago
parent
commit
0ed502d8a3

+ 3 - 1
mapreduce/CHANGES.txt

@@ -3,7 +3,9 @@ Hadoop MapReduce Change Log
 Trunk (unreleased changes)
 
   MAPREDUCE-279
-   
+
+    Fixed CS locality wait factor. (acmurthy)
+
     MAPREDUCE-2781. mr279 RM application finishtime not set 
     (thomas graves via mahadev)
     

+ 1 - 1
mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java

@@ -832,7 +832,7 @@ public class LeafQueue implements Queue {
         application.getLocalityWaitFactor(priority, 
             scheduler.getNumClusterNodes());
       
-      return ((requiredContainers * localityWaitFactor) > missedOpportunities);
+      return ((requiredContainers * localityWaitFactor) < missedOpportunities);
     }
 
     // Check if we need containers on this rack