big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-10286. PendingContainers bugs in the scheduler outputs. Contributed by Andras Gyori

Browse Source
This commit is contained in:
Szilard Nemeth 2020-06-02 15:41:10 +02:00
parent 9fe4c37c25
commit e0a0741ac8
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java
View File

@ -60,6 +60,7 @@ public class FairSchedulerQueueInfo {
private ResourceInfo reservedResources; private ResourceInfo reservedResources;
private ResourceInfo maxContainerAllocation; private ResourceInfo maxContainerAllocation;
private long pendingContainers;
private long allocatedContainers; private long allocatedContainers;
private long reservedContainers; private long reservedContainers;
@ -108,6 +109,7 @@ public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) {
allocatedContainers = queue.getMetrics().getAllocatedContainers(); allocatedContainers = queue.getMetrics().getAllocatedContainers();
reservedContainers = queue.getMetrics().getReservedContainers(); reservedContainers = queue.getMetrics().getReservedContainers();
pendingContainers = queue.getMetrics().getPendingContainers();
if (allocConf.isReservable(queueName) && if (allocConf.isReservable(queueName) &&
!allocConf.getShowReservationAsQueues(queueName)) { !allocConf.getShowReservationAsQueues(queueName)) {
@ -122,6 +124,8 @@ public long getAllocatedContainers() {
return allocatedContainers; return allocatedContainers;
} }
public long getPendingContainers() { return pendingContainers; }
public long getReservedContainers() { public long getReservedContainers() {
return reservedContainers; return reservedContainers;
} }

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md
View File

@ -338,6 +338,9 @@ The capacity scheduler supports hierarchical queues. This one request will print
| numActiveApplications | int | The number of active applications in this queue | | numActiveApplications | int | The number of active applications in this queue |
| numPendingApplications | int | The number of pending applications in this queue | | numPendingApplications | int | The number of pending applications in this queue |
| numContainers | int | The number of containers being used | | numContainers | int | The number of containers being used |
| allocatedContainers | int | The number of allocated containers in this queue |
| reservedContainers | int | The number of reserved containers in this queue |
| pendingContainers | int | The number of pending containers in this queue |
| maxApplications | int | The maximum number of applications this queue can have | | maxApplications | int | The maximum number of applications this queue can have |
| maxApplicationsPerUser | int | The maximum number of applications per user this queue can have | | maxApplicationsPerUser | int | The maximum number of applications per user this queue can have |
| maxActiveApplications | int | The maximum number of active applications this queue can have | | maxActiveApplications | int | The maximum number of active applications this queue can have |