You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by sh...@apache.org on 2011/02/04 23:56:50 UTC
svn commit: r1067325 - in /hadoop/mapreduce/branches/branch-0.22: CHANGES.txt
src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java
Author: shv
Date: Fri Feb 4 22:56:50 2011
New Revision: 1067325
URL: http://svn.apache.org/viewvc?rev=1067325&view=rev
Log:
MAPREDUCE-1974. Merge r1067321 from trunk to 0.22.
Modified:
hadoop/mapreduce/branches/branch-0.22/CHANGES.txt
hadoop/mapreduce/branches/branch-0.22/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java
Modified: hadoop/mapreduce/branches/branch-0.22/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.22/CHANGES.txt?rev=1067325&r1=1067324&r2=1067325&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.22/CHANGES.txt (original)
+++ hadoop/mapreduce/branches/branch-0.22/CHANGES.txt Fri Feb 4 22:56:50 2011
@@ -469,6 +469,9 @@ Release 0.22.0 - Unreleased
MAPREDUCE-1915. Fix IndexOutOfBoundsException in IndexCache.
(Priyo Mustafi via shv)
+ MAPREDUCE-1974. Fix multiple preemtions of the same task in FairScheduler.
+ (Scott Chen via shv)
+
Release 0.21.1 - Unreleased
NEW FEATURES
Modified: hadoop/mapreduce/branches/branch-0.22/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.22/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java?rev=1067325&r1=1067324&r2=1067325&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.22/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java (original)
+++ hadoop/mapreduce/branches/branch-0.22/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/FairScheduler.java Fri Feb 4 22:56:50 2011
@@ -931,7 +931,7 @@ public class FairScheduler extends TaskS
private List<TaskStatus> getRunningTasks(JobInProgress job, TaskType type) {
// Create a list of all running TaskInProgress'es in the job
- List<TaskInProgress> tips = new ArrayList<TaskInProgress>();
+ Set<TaskInProgress> tips = new HashSet<TaskInProgress>();
if (type == TaskType.MAP) {
// Jobs may have both "non-local maps" which have a split with no locality
// info (e.g. the input file is not in HDFS), and maps with locality info,