Author: acmurthy
Date: Thu Aug 11 17:53:20 2011
New Revision: 1156707
URL: http://svn.apache.org/viewvc?rev=1156707&view=rev
Log:
Fixed CS locality wait factor.
Modified:
hadoop/common/branches/MR-279/mapreduce/CHANGES.txt
hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Modified: hadoop/common/branches/MR-279/mapreduce/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/MR-279/mapreduce/CHANGES.txt?rev=1156707&r1=1156706&r2=1156707&view=diff
==============================================================================
--- hadoop/common/branches/MR-279/mapreduce/CHANGES.txt (original)
+++ hadoop/common/branches/MR-279/mapreduce/CHANGES.txt Thu Aug 11 17:53:20 2011
@@ -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)
Modified: hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java?rev=1156707&r1=1156706&r2=1156707&view=diff
==============================================================================
--- hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
(original)
+++ hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Thu Aug 11 17:53:20 2011
@@ -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
|