From e722f2f49fd1133c7febb55932a4277e1d69465f Mon Sep 17 00:00:00 2001 From: Akshay Rai Date: Tue, 13 Dec 2016 12:10:31 +0530 Subject: [PATCH] LIHADOOP-24958: Investigate the cause of Skipped Jobs Alert in Dr. Elephant --- .../drelephant/analysis/AnalyticJobGeneratorHadoop2.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java b/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java index e80251f25..0389b3191 100644 --- a/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java +++ b/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java @@ -141,9 +141,11 @@ public List fetchAnalyticJobs() appList.addAll(succeededApps); // Fetch all failed apps + // state: Application Master State + // finalStatus: Status of the Application as reported by the Application Master URL failedAppsURL = new URL(new URL("http://" + _resourceManagerAddress), String.format( - "/ws/v1/cluster/apps?finalStatus=FAILED&finishedTimeBegin=%s&finishedTimeEnd=%s", - String.valueOf(_lastTime + 1), String.valueOf(_currentTime))); + "/ws/v1/cluster/apps?finalStatus=FAILED&state=FINISHED&finishedTimeBegin=%s&finishedTimeEnd=%s", + String.valueOf(_lastTime + 1), String.valueOf(_currentTime))); List failedApps = readApps(failedAppsURL); logger.info("The failed apps URL is " + failedAppsURL); appList.addAll(failedApps);