Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-3369. Missing NullPointer check in AppSchedulingInfo causes RM to die. (Brahma Reddy Battula via wangda)

Browse Source 
(cherry picked from commit 6bc7710ec7f2592c4c87dd940fbe5827ef81fe72)
(cherry picked from commit 8e142d27cbddfa1a1c83c5f8752bd14ac0a13612)
(cherry picked from commit 4d43be3c01b1bc0deb31a9081fca5395d0eb4e0d)
This commit is contained in:
Wangda Tan 2015-03-20 10:42:05 -07:00 committed by Vinod Kumar Vavilapalli
parent 553efd7190
commit 005d865494
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -114,6 +114,9 @@ Release 2.6.1 - UNRELEASED
YARN-3267. Timelineserver applies the ACL rules after applying the limit on YARN-3267. Timelineserver applies the ACL rules after applying the limit on
the number of records (Chang Li via jeagles) the number of records (Chang Li via jeagles)
YARN-3369. Missing NullPointer check in AppSchedulingInfo causes RM to die.
(Brahma Reddy Battula via wangda)
Release 2.6.0 - 2014-11-18 Release 2.6.0 - 2014-11-18
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AppSchedulingInfo.java
View File

@ -236,7 +236,7 @@ synchronized public ResourceRequest getResourceRequest(Priority priority,
public synchronized Resource getResource(Priority priority) { public synchronized Resource getResource(Priority priority) {
ResourceRequest request = getResourceRequest(priority, ResourceRequest.ANY); ResourceRequest request = getResourceRequest(priority, ResourceRequest.ANY);
return request.getCapability(); return (request == null) ? null : request.getCapability();
} }
public synchronized boolean isBlacklisted(String resourceName) { public synchronized boolean isBlacklisted(String resourceName) {
@ -380,11 +380,13 @@ synchronized private void checkForDeactivation() {
boolean deactivate = true; boolean deactivate = true;
for (Priority priority : getPriorities()) { for (Priority priority : getPriorities()) {
ResourceRequest request = getResourceRequest(priority, ResourceRequest.ANY); ResourceRequest request = getResourceRequest(priority, ResourceRequest.ANY);
if (request != null) {
if (request.getNumContainers() > 0) { if (request.getNumContainers() > 0) {
deactivate = false; deactivate = false;
break; break;
} }
} }
}
if (deactivate) { if (deactivate) {
activeUsersManager.deactivateApplication(user, applicationId); activeUsersManager.deactivateApplication(user, applicationId);
} }