Author: acmurthy
Date: Wed May 11 08:31:55 2011
New Revision: 1101783
URL: http://svn.apache.org/viewvc?rev=1101783&view=rev
Log:
Fixed delay scheduling
Modified:
hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Modified:
hadoop/mapreduce/branches/MR-279/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/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java?rev=1101783&r1=1101782&r2=1101783&view=diff
==============================================================================
---
hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
(original)
+++
hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Wed May 11 08:31:55 2011
@@ -769,7 +769,7 @@ public class LeafQueue implements Queue
scheduler.getNumClusterNodes());
if (requiredContainers > 0) {
- if ((requiredContainers * localityWaitFactor) < missedNodes) {
+ if (missedNodes < (requiredContainers * localityWaitFactor)) {
LOG.info("Application " + application.getApplicationId() +
" has missed " + missedNodes + " opportunities," +
" waitFactor= " + localityWaitFactor +
