diff --git a/lipstick-console/src/main/java/com/netflix/lipstick/warnings/JobWarnings.java b/lipstick-console/src/main/java/com/netflix/lipstick/warnings/JobWarnings.java index 8dc13ab..6b4fdd8 100644 --- a/lipstick-console/src/main/java/com/netflix/lipstick/warnings/JobWarnings.java +++ b/lipstick-console/src/main/java/com/netflix/lipstick/warnings/JobWarnings.java @@ -159,13 +159,17 @@ public List findSkewedReducers(List reducerTimes) { } public List enumerateReducerRunTimesAccending(JobClient jobClient, String jobId) { - try { - TaskReport[] reduceTasks = jobClient.getReduceTaskReports(jobId); - return enumerateReducerRunTimesAccending(reduceTasks); - } catch (IOException e) { - log.error("Error getting reduce task reports, continuing", e); - return Lists.newArrayList(); + if (!jobClient.getConf().getBoolean("pig.stats.notaskreport", false)) { + try { + TaskReport[] reduceTasks = jobClient.getReduceTaskReports(jobId); + return enumerateReducerRunTimesAccending(reduceTasks); + } catch (IOException e) { + log.error("Error getting reduce task reports, continuing", e); + } + } else { + log.info("Skipping reduce task reports for job " + jobId); } + return Lists.newArrayList(); } /* Extract all running or completed reducer tasks for the job, their runtime and sort them