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

YARN-10685. Fix typos in AbstractCSQueue. Contributed by Qi Zhu.

Browse Source
This commit is contained in:
Peter Bacsko 2021-03-18 11:49:16 +01:00
parent 49f89f1d3d
commit d7eeca4d0c
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractCSQueue.java
View File

@ -114,7 +114,8 @@ public abstract class AbstractCSQueue implements CSQueue {
private final boolean fullPathQueueNamingPolicy = false; private final boolean fullPathQueueNamingPolicy = false;
// Track capacities like used-capcity/abs-used-capacity/capacity/abs-capacity, // Track capacities like
// used-capacity/abs-used-capacity/capacity/abs-capacity,
// etc. // etc.
QueueCapacities queueCapacities; QueueCapacities queueCapacities;
@ -962,7 +963,7 @@ private long getInheritedDefaultAppLifetime(CSQueue q,
if (defaultAppLifetime < 0) { if (defaultAppLifetime < 0) {
// If default lifetime was not set at this level but was set somewhere in // If default lifetime was not set at this level but was set somewhere in
// the parent's hierarchy, set default lifetime to parent queue's default // the parent's hierarchy, set default lifetime to parent queue's default
// only if parent queue's lifetime is less than current queueu's max // only if parent queue's lifetime is less than current queue's max
// lifetime. Otherwise, use current queue's max lifetime value for its // lifetime. Otherwise, use current queue's max lifetime value for its
// default lifetime. // default lifetime.
if (defaultAppLifetimeWasSpecifiedInConfig) { if (defaultAppLifetimeWasSpecifiedInConfig) {
@ -1012,7 +1013,7 @@ private boolean isIntraQueueHierarchyPreemptionDisabled(CSQueue q,
// At this point, the master preemption switch is enabled down to this // At this point, the master preemption switch is enabled down to this
// queue's level. Determine whether or not intra-queue preemption is enabled // queue's level. Determine whether or not intra-queue preemption is enabled
// down to this queu's level and return that value. // down to this queue's level and return that value.
return configuration.getIntraQueuePreemptionDisabled(q.getQueuePath(), return configuration.getIntraQueuePreemptionDisabled(q.getQueuePath(),
parentQ.getIntraQueuePreemptionDisabledInHierarchy()); parentQ.getIntraQueuePreemptionDisabledInHierarchy());
} }
@ -1065,7 +1066,7 @@ boolean canAssignToThisQueue(Resource clusterResource,
// Doing this because: for non-exclusive allocation, we make sure there's // Doing this because: for non-exclusive allocation, we make sure there's
// idle resource on the partition, to avoid wastage, such resource will be // idle resource on the partition, to avoid wastage, such resource will be
// leveraged as much as we can, and preemption policy will reclaim it back // leveraged as much as we can, and preemption policy will reclaim it back
// when partitoned-resource-request comes back. // when partitioned-resource-request comes back.
Resource currentLimitResource = getCurrentLimitResource(nodePartition, Resource currentLimitResource = getCurrentLimitResource(nodePartition,
clusterResource, currentResourceLimits, schedulingMode); clusterResource, currentResourceLimits, schedulingMode);
@ -1115,7 +1116,7 @@ boolean canAssignToThisQueue(Resource clusterResource,
// Can not assign to this queue // Can not assign to this queue
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("Failed to assign to queue: " + getQueuePath() LOG.debug("Failed to assign to queue: " + getQueuePath()
+ " nodePatrition: " + nodePartition + " nodePartition: " + nodePartition
+ ", usedResources: " + queueUsage.getUsed(nodePartition) + ", usedResources: " + queueUsage.getUsed(nodePartition)
+ ", clusterResources: " + clusterResource + ", clusterResources: " + clusterResource
+ ", reservedResources: " + resourceCouldBeUnreserved + ", reservedResources: " + resourceCouldBeUnreserved