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 tu...@apache.org on 2012/11/17 07:16:59 UTC
svn commit: r1410701 - in
/hadoop/common/branches/branch-2/hadoop-mapreduce-project: CHANGES.txt
hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
Author: tucu
Date: Sat Nov 17 06:16:58 2012
New Revision: 1410701
URL: http://svn.apache.org/viewvc?rev=1410701&view=rev
Log:
MAPREDUCE-4800. Cleanup o.a.h.mapred.MapTaskStatus - remove unused code. (kkambatl via tucu)
Modified:
hadoop/common/branches/branch-2/hadoop-mapreduce-project/CHANGES.txt
hadoop/common/branches/branch-2/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
Modified: hadoop/common/branches/branch-2/hadoop-mapreduce-project/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2/hadoop-mapreduce-project/CHANGES.txt?rev=1410701&r1=1410700&r2=1410701&view=diff
==============================================================================
--- hadoop/common/branches/branch-2/hadoop-mapreduce-project/CHANGES.txt (original)
+++ hadoop/common/branches/branch-2/hadoop-mapreduce-project/CHANGES.txt Sat Nov 17 06:16:58 2012
@@ -48,6 +48,9 @@ Release 2.0.3-alpha - Unreleased
MAPREDUCE-4777. In TestIFile, testIFileReaderWithCodec relies on
testIFileWriterWithCodec. (Sandy Ryza via tomwhite)
+ MAPREDUCE-4800. Cleanup o.a.h.mapred.MapTaskStatus - remove unused
+ code. (kkambatl via tucu)
+
Release 2.0.2-alpha - 2012-09-07
INCOMPATIBLE CHANGES
Modified: hadoop/common/branches/branch-2/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java?rev=1410701&r1=1410700&r2=1410701&view=diff
==============================================================================
--- hadoop/common/branches/branch-2/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java (original)
+++ hadoop/common/branches/branch-2/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java Sat Nov 17 06:16:58 2012
@@ -25,8 +25,7 @@ import java.io.IOException;
class MapTaskStatus extends TaskStatus {
- private long mapFinishTime;
- private long sortFinishTime;
+ private long mapFinishTime = 0;
public MapTaskStatus() {}
@@ -49,10 +48,10 @@ class MapTaskStatus extends TaskStatus {
@Override
void setFinishTime(long finishTime) {
super.setFinishTime(finishTime);
- if (mapFinishTime == 0) {
- mapFinishTime = finishTime;
+ // set mapFinishTime if it hasn't been set before
+ if (getMapFinishTime() == 0) {
+ setMapFinishTime(finishTime);
}
- setSortFinishTime(finishTime);
}
@Override
@@ -74,16 +73,6 @@ class MapTaskStatus extends TaskStatus {
void setMapFinishTime(long mapFinishTime) {
this.mapFinishTime = mapFinishTime;
}
-
- @Override
- public long getSortFinishTime() {
- return sortFinishTime;
- }
-
- @Override
- void setSortFinishTime(long sortFinishTime) {
- this.sortFinishTime = sortFinishTime;
- }
@Override
synchronized void statusUpdate(TaskStatus status) {