hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ama...@apache.org
Subject svn commit: r1195548 - in /hadoop/common/branches/branch-0.23/hadoop-mapreduce-project: CHANGES.txt src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
Date Mon, 31 Oct 2011 16:19:06 GMT
Author: amarrk
Date: Mon Oct 31 16:19:05 2011
New Revision: 1195548

URL: http://svn.apache.org/viewvc?rev=1195548&view=rev
Log:
MAPREDUCE-3241. [Rumen] Fix Rumen to ignore the AMStartedEvent. (amarrk)

Modified:
    hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt
    hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java

Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt?rev=1195548&r1=1195547&r2=1195548&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt Mon Oct 31 16:19:05
2011
@@ -1,4 +1,6 @@
 Hadoop MapReduce Change Log
+    MAPREDUCE-3241. [Rumen] Fix Rumen to ignore the AMStartedEvent. (amarrk)
+
     MAPREDUCE-3166. [Rumen] Make Rumen use job history api instead of relying
     on current history file name format. (Ravi Gummadi via amarrk)
 

Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java?rev=1195548&r1=1195547&r2=1195548&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
(original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
Mon Oct 31 16:19:05 2011
@@ -28,6 +28,7 @@ import java.util.regex.Pattern;
 
 import org.apache.hadoop.mapred.TaskStatus;
 import org.apache.hadoop.mapreduce.TaskType;
+import org.apache.hadoop.mapreduce.jobhistory.AMStartedEvent;
 import org.apache.hadoop.mapreduce.jobhistory.HistoryEvent;
 import org.apache.hadoop.mapreduce.jobhistory.JobFinishedEvent;
 import org.apache.hadoop.mapreduce.jobhistory.JobInfoChangeEvent;
@@ -129,7 +130,11 @@ public class JobBuilder {
     }
 
     // these are in lexicographical order by class name.
-    if (event instanceof JobFinishedEvent) {
+    if (event instanceof AMStartedEvent) {
+      // ignore this event as Rumen currently doesnt need this event
+      //TODO Enhance Rumen to process this event and capture restarts
+      return;
+    } else if (event instanceof JobFinishedEvent) {
       processJobFinishedEvent((JobFinishedEvent) event);
     } else if (event instanceof JobInfoChangeEvent) {
       processJobInfoChangeEvent((JobInfoChangeEvent) event);



Mime
View raw message