Skip to content

Commit d7eeca4

Browse files
committed
YARN-10685. Fix typos in AbstractCSQueue. Contributed by Qi Zhu.
1 parent 49f89f1 commit d7eeca4

File tree

1 file changed

+6
-5
lines changed
  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity

1 file changed

+6
-5
lines changed

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

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,8 @@ public abstract class AbstractCSQueue implements CSQueue {
114114

115115
private final boolean fullPathQueueNamingPolicy = false;
116116

117-
// Track capacities like used-capcity/abs-used-capacity/capacity/abs-capacity,
117+
// Track capacities like
118+
// used-capacity/abs-used-capacity/capacity/abs-capacity,
118119
// etc.
119120
QueueCapacities queueCapacities;
120121

@@ -962,7 +963,7 @@ private long getInheritedDefaultAppLifetime(CSQueue q,
962963
if (defaultAppLifetime < 0) {
963964
// If default lifetime was not set at this level but was set somewhere in
964965
// the parent's hierarchy, set default lifetime to parent queue's default
965-
// only if parent queue's lifetime is less than current queueu's max
966+
// only if parent queue's lifetime is less than current queue's max
966967
// lifetime. Otherwise, use current queue's max lifetime value for its
967968
// default lifetime.
968969
if (defaultAppLifetimeWasSpecifiedInConfig) {
@@ -1012,7 +1013,7 @@ private boolean isIntraQueueHierarchyPreemptionDisabled(CSQueue q,
10121013

10131014
// At this point, the master preemption switch is enabled down to this
10141015
// queue's level. Determine whether or not intra-queue preemption is enabled
1015-
// down to this queu's level and return that value.
1016+
// down to this queue's level and return that value.
10161017
return configuration.getIntraQueuePreemptionDisabled(q.getQueuePath(),
10171018
parentQ.getIntraQueuePreemptionDisabledInHierarchy());
10181019
}
@@ -1065,7 +1066,7 @@ boolean canAssignToThisQueue(Resource clusterResource,
10651066
// Doing this because: for non-exclusive allocation, we make sure there's
10661067
// idle resource on the partition, to avoid wastage, such resource will be
10671068
// leveraged as much as we can, and preemption policy will reclaim it back
1068-
// when partitoned-resource-request comes back.
1069+
// when partitioned-resource-request comes back.
10691070
Resource currentLimitResource = getCurrentLimitResource(nodePartition,
10701071
clusterResource, currentResourceLimits, schedulingMode);
10711072

@@ -1115,7 +1116,7 @@ boolean canAssignToThisQueue(Resource clusterResource,
11151116
// Can not assign to this queue
11161117
if (LOG.isDebugEnabled()) {
11171118
LOG.debug("Failed to assign to queue: " + getQueuePath()
1118-
+ " nodePatrition: " + nodePartition
1119+
+ " nodePartition: " + nodePartition
11191120
+ ", usedResources: " + queueUsage.getUsed(nodePartition)
11201121
+ ", clusterResources: " + clusterResource
11211122
+ ", reservedResources: " + resourceCouldBeUnreserved

0 commit comments

Comments
 (0)