Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

svn merge -c 1443257 FIXES: MAPREDUCE-4822. Unnecessary conversions in History Events. Contributed by Chu Tong 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1443269 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jason Darrell Lowe 2013-02-06 22:58:09 +00:00
parent f5503bd44a
commit 2db13d61c2
5 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -550,6 +550,9 @@ Release 0.23.7 - UNRELEASED
MAPREDUCE-4946. Fix a performance problem for large jobs by reducing the
number of map completion event type conversions. (Jason Lowe via sseth)
MAPREDUCE-4822. Unnecessary conversions in History Events. (Chu Tong via
jlowe)
BUG FIXES
MAPREDUCE-4458. Warn if java.library.path is used for AM or Task

2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java
View File

@ -178,7 +178,7 @@ public class MapAttemptFinishedEvent implements HistoryEvent {
/** Get the task type */
public TaskType getTaskType() {
return TaskType.valueOf(taskType.toString());
return taskType;
}
/** Get the task status */
public String getTaskStatus() { return taskStatus.toString(); }

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java
View File

@ -176,11 +176,11 @@ public class ReduceAttemptFinishedEvent implements HistoryEvent {
public TaskID getTaskId() { return attemptId.getTaskID(); }
/** Get the attempt id */
public TaskAttemptID getAttemptId() {
return TaskAttemptID.forName(attemptId.toString());
return attemptId;
}
/** Get the task type */
public TaskType getTaskType() {
return TaskType.valueOf(taskType.toString());
return taskType;
}
/** Get the task status */
public String getTaskStatus() { return taskStatus.toString(); }

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java
View File

@ -105,11 +105,11 @@ public class TaskAttemptFinishedEvent implements HistoryEvent {
public TaskID getTaskId() { return attemptId.getTaskID(); }
/** Get the task attempt id */
public TaskAttemptID getAttemptId() {
return TaskAttemptID.forName(attemptId.toString());
return attemptId;
}
/** Get the task type */
public TaskType getTaskType() {
return TaskType.valueOf(taskType.toString());
return taskType;
}
/** Get the task status */
public String getTaskStatus() { return taskStatus.toString(); }

10
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java
View File

@ -95,14 +95,10 @@ public class TaskFinishedEvent implements HistoryEvent {
}
/** Get task id */
public TaskID getTaskId() { return TaskID.forName(taskid.toString()); }
public TaskID getTaskId() { return taskid; }
/** Get successful task attempt id */
public TaskAttemptID getSuccessfulTaskAttemptId() {
if(successfulAttemptId != null)
{
return TaskAttemptID.forName(successfulAttemptId.toString());
}
return null;
return successfulAttemptId;
}
/** Get the task finish time */
public long getFinishTime() { return finishTime; }
@ -110,7 +106,7 @@ public class TaskFinishedEvent implements HistoryEvent {
public Counters getCounters() { return counters; }
/** Get task type */
public TaskType getTaskType() {
return TaskType.valueOf(taskType.toString());
return taskType;
}
/** Get task status */
public String getTaskStatus() { return status.toString(); }