Author: tucu
Date: Sat Nov 17 06:08:06 2012
New Revision: 1410700
URL: http://svn.apache.org/viewvc?rev=1410700&view=rev
Log:
MAPREDUCE-4800. Cleanup o.a.h.mapred.MapTaskStatus - remove unused code.
(kkambatl via tucu)
Modified:
hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
Modified: hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt?rev=1410700&r1=1410699&r2=1410700&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-mapreduce-project/CHANGES.txt Sat Nov 17
06:08:06 2012
@@ -199,6 +199,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/trunk/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/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java?rev=1410700&r1=1410699&r2=1410700&view=diff
==============================================================================
---
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
(original)
+++
hadoop/common/trunk/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTaskStatus.java
Sat Nov 17 06:08:06 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) {
