diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java index 2a6657aa5df..0ed76c98c85 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java @@ -1199,14 +1199,22 @@ private boolean isUsageBelowShare(Resource usage, Resource share) { * @return true if the app is starved for fairshare, false otherwise */ boolean isStarvedForFairShare() { - return isUsageBelowShare(getResourceUsage(), getFairShare()); + return !Resources.isNone(fairshareStarvation); + } + + /** + * Helper method that captures if this app is identified to be starved. + * @return true if the app is starved for minshare, false otherwise + */ + boolean isStarvedForMinShare() { + return !Resources.isNone(minshareStarvation); } /** * Is application starved for fairshare or minshare. */ boolean isStarved() { - return isStarvedForFairShare() || !Resources.isNone(minshareStarvation); + return isStarvedForFairShare() || isStarvedForMinShare(); } /**