From 44e35dcd98f844113467581f24b393eb4b3086bc Mon Sep 17 00:00:00 2001 From: Arpan Agrawal Date: Fri, 23 Feb 2018 15:16:06 +0530 Subject: [PATCH] Bug fix: Delay computation of MR application (#340) --- .../drelephant/mapreduce/MapReduceMetricsAggregator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);