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

pralabhkumar · Aug 31, 2018 · 44e35dc · 44e35dc
1 parent e18f2fb
commit 44e35dc
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);