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

Fix a typo 

I think there is a typo unless you typed intentionally. Is `slowTaskRelativeTresholds` meant to be `slowTaskRelativeThresholds`?
This commit is contained in:
iSultan 2015-12-08 19:27:50 -05:00
parent 7e4715186d
commit 91affcc607
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/StartEndTimesBase.java
View File

@ -61,7 +61,7 @@ abstract class StartEndTimesBase implements TaskRuntimeEstimator {
= new HashMap<Job, DataStatistics>(); = new HashMap<Job, DataStatistics>();
private final Map<Job, Float> slowTaskRelativeTresholds private final Map<Job, Float> slowTaskRelativeThresholds
= new HashMap<Job, Float>(); = new HashMap<Job, Float>();
protected final Set<Task> doneTasks = new HashSet<Task>(); protected final Set<Task> doneTasks = new HashSet<Task>();
@ -89,7 +89,7 @@ abstract class StartEndTimesBase implements TaskRuntimeEstimator {
final Job job = entry.getValue(); final Job job = entry.getValue();
mapperStatistics.put(job, new DataStatistics()); mapperStatistics.put(job, new DataStatistics());
reducerStatistics.put(job, new DataStatistics()); reducerStatistics.put(job, new DataStatistics());
slowTaskRelativeTresholds.put slowTaskRelativeThresholds.put
(job, conf.getFloat(MRJobConfig.SPECULATIVE_SLOWTASK_THRESHOLD,1.0f)); (job, conf.getFloat(MRJobConfig.SPECULATIVE_SLOWTASK_THRESHOLD,1.0f));
} }
} }
@ -141,7 +141,7 @@ abstract class StartEndTimesBase implements TaskRuntimeEstimator {
long result = statistics == null long result = statistics == null
? Long.MAX_VALUE ? Long.MAX_VALUE
: (long)statistics.outlier(slowTaskRelativeTresholds.get(job)); : (long)statistics.outlier(slowTaskRelativeThresholds.get(job));
return result; return result;
} }