You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ac...@apache.org on 2007/11/21 16:14:18 UTC
svn commit: r597109 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/TaskInProgress.java
Author: acmurthy
Date: Wed Nov 21 07:14:17 2007
New Revision: 597109
URL: http://svn.apache.org/viewvc?rev=597109&view=rev
Log:
HADOOP-1281. Kill map-tasks when the parent TaskInProgress has been completed by another (possibly speculative) map-task. This ensures that map-slots are not needlessly held-up.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskInProgress.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=597109&r1=597108&r2=597109&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Wed Nov 21 07:14:17 2007
@@ -115,6 +115,10 @@
HADOOP-2078. An zero size file may have no blocks associated with it.
(Konstantin Shvachko via dhruba)
+ HADOOP-1281. Kill map-tasks when the parent TaskInProgress has been
+ completed by another (possibly speculative) map-task. This ensures that
+ map-slots are not needlessly held-up. (acmurthy)
+
Release 0.15.1 - 2007-11-27
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskInProgress.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskInProgress.java?rev=597109&r1=597108&r2=597109&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskInProgress.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskInProgress.java Wed Nov 21 07:14:17 2007
@@ -330,8 +330,7 @@
(job.getStatus().getRunState() != JobStatus.RUNNING)) {
tasksReportedClosed.add(taskid);
return true;
- } else if (!isMapTask() && isComplete() &&
- !tasksReportedClosed.contains(taskid)){
+ } else if (isComplete() && !tasksReportedClosed.contains(taskid)) {
tasksReportedClosed.add(taskid);
return true;
} else {