This is an automated email from the ASF dual-hosted git repository.
snemeth pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new a266e32 YARN-10286. PendingContainers bugs in the scheduler outputs.
Contributed by Andras Gyori
a266e32 is described below
commit a266e32d8243e4f50e81d3fd2d775b07a2d33214
Author: Szilard Nemeth <snem...@apache.org>
AuthorDate: Fri Jun 5 09:50:43 2020 +0200
YARN-10286. PendingContainers bugs in the scheduler outputs. Contributed by
Andras Gyori
---
.../server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java | 4 ++++
.../hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md | 3 +++
2 files changed, 7 insertions(+)
diff --git
a/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
b/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
index f28e5b2..9804a36 100644
---
a/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
+++
b/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
@@ -60,6 +60,7 @@ public class FairSchedulerQueueInfo {
private ResourceInfo reservedResources;
private ResourceInfo maxContainerAllocation;
+ private long pendingContainers;
private long allocatedContainers;
private long reservedContainers;
@@ -108,6 +109,7 @@ public class FairSchedulerQueueInfo {
allocatedContainers = queue.getMetrics().getAllocatedContainers();
reservedContainers = queue.getMetrics().getReservedContainers();
+ pendingContainers = queue.getMetrics().getPendingContainers();
if (allocConf.isReservable(queueName) &&
!allocConf.getShowReservationAsQueues(queueName)) {
@@ -122,6 +124,8 @@ public class FairSchedulerQueueInfo {
return allocatedContainers;
}
+ public long getPendingContainers() { return pendingContainers; }
+
public long getReservedContainers() {
return reservedContainers;
}
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md
index 4b8c2cb..a30221d 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-site/src/site/markdown/ResourceManagerRest.md
@@ -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 |
| numPendingApplications | int | The number of pending applications in this
queue |
| 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 |
| 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 |
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
