diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 6d7ffdf52d..832a3f35b5 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -314,7 +314,11 @@ Release 2.0.5-beta - UNRELEASED MAPREDUCE-5128. mapred-default.xml is missing a bunch of history server configs. (sandyr via tucu) - MAPREDUCE-4898. FileOutputFormat.checkOutputSpecs and FileOutputFormat.setOutputPath incompatible with MR1. (rkanter via tucu) + MAPREDUCE-4898. FileOutputFormat.checkOutputSpecs and + FileOutputFormat.setOutputPath incompatible with MR1. (rkanter via tucu) + + MAPREDUCE-4932. mapreduce.job#getTaskCompletionEvents incompatible with + Hadoop 1. (rkanter via tucu) Release 2.0.4-alpha - UNRELEASED diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java index abbe1e194c..90cf660fd2 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Job.java @@ -659,8 +659,24 @@ public class Job extends JobContextImpl implements JobContext { startFrom, numEvents); } }); + } + + /** + * Get events indicating completion (success/failure) of component tasks. + * + * @param startFrom index to start fetching events from + * @return an array of {@link TaskCompletionEvent}s + * @throws IOException + */ + public TaskCompletionEvent[] getTaskCompletionEvents(final int startFrom) + throws IOException { + try { + return getTaskCompletionEvents(startFrom, 10); + } catch (InterruptedException ie) { + throw new RuntimeException(ie); } - + } + /** * Kill indicated task attempt. *