LIHADOOP-24958: Investigate the cause of Skipped Jobs Alert in Dr. El…

…ephant
adbadb · Dec 13, 2016 · e722f2f · e722f2f
1 parent 0c0ebb2
commit e722f2f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java b/app/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2.java
@@ -141,9 +141,11 @@ public List<AnalyticJob> 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<AnalyticJob> failedApps = readApps(failedAppsURL);
     logger.info("The failed apps URL is " + failedAppsURL);
     appList.addAll(failedApps);