|
@@ -244,7 +244,8 @@ public class SchedulerApplicationAttempt implements SchedulableEntity {
|
|
}
|
|
}
|
|
|
|
|
|
public synchronized int getTotalRequiredResources(Priority priority) {
|
|
public synchronized int getTotalRequiredResources(Priority priority) {
|
|
- return getResourceRequest(priority, ResourceRequest.ANY).getNumContainers();
|
|
|
|
|
|
+ ResourceRequest request = getResourceRequest(priority, ResourceRequest.ANY);
|
|
|
|
+ return request == null ? 0 : request.getNumContainers();
|
|
}
|
|
}
|
|
|
|
|
|
public synchronized Resource getResource(Priority priority) {
|
|
public synchronized Resource getResource(Priority priority) {
|