diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/StartEndTimesBase.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/StartEndTimesBase.java index 8eda00528f..be35b68a56 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/StartEndTimesBase.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/StartEndTimesBase.java @@ -61,7 +61,7 @@ abstract class StartEndTimesBase implements TaskRuntimeEstimator { = new HashMap(); - private final Map slowTaskRelativeTresholds + private final Map slowTaskRelativeThresholds = new HashMap(); protected final Set doneTasks = new HashSet(); @@ -89,7 +89,7 @@ public void contextualize(Configuration conf, AppContext context) { final Job job = entry.getValue(); mapperStatistics.put(job, new DataStatistics()); reducerStatistics.put(job, new DataStatistics()); - slowTaskRelativeTresholds.put + slowTaskRelativeThresholds.put (job, conf.getFloat(MRJobConfig.SPECULATIVE_SLOWTASK_THRESHOLD,1.0f)); } } @@ -141,7 +141,7 @@ public long thresholdRuntime(TaskId taskID) { long result = statistics == null ? Long.MAX_VALUE - : (long)statistics.outlier(slowTaskRelativeTresholds.get(job)); + : (long)statistics.outlier(slowTaskRelativeThresholds.get(job)); return result; }