Bug fix: Delay computation of MR application (linkedin#340)

meteorchenwu · Feb 23, 2018 · 8ea2850 · 8ea2850
1 parent b2c24b8
commit 8ea2850
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);