diff --git a/app/com/linkedin/drelephant/mapreduce/MapReduceMetricsAggregator.java b/app/com/linkedin/drelephant/mapreduce/MapReduceMetricsAggregator.java index 8d2004c0e..c83dc6bce 100644 --- a/app/com/linkedin/drelephant/mapreduce/MapReduceMetricsAggregator.java +++ b/app/com/linkedin/drelephant/mapreduce/MapReduceMetricsAggregator.java @@ -59,7 +59,7 @@ public void aggregate(HadoopApplicationData hadoopData) { //overwrite reduceTaskSlowStartPercentage to 100%. TODO: make use of the slow start percent reduceTaskSlowStartPercentage = 100; - mapTasks = new TaskLevelAggregatedMetrics(data.getMapperData(), mapTaskContainerSize, data.getStartTime()); + mapTasks = new TaskLevelAggregatedMetrics(data.getMapperData(), mapTaskContainerSize, data.getSubmitTime()); long reduceIdealStartTime = mapTasks.getNthPercentileFinishTime(reduceTaskSlowStartPercentage);