Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-10488. Several typos in package: org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair (#2485) 

Co-authored-by: akumar <akumar@cloudera.com>
Reviewed-by: Wei-Chiu Chuang <weichiu@apache.org>
Reviewed-by: Akira Ajisaka <aajisaka@apache.org>
This commit is contained in:
Ankit Kumar 2020-11-25 05:00:09 +01:00 committed by GitHub
parent 569b20e31c
commit 08b2e285db
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java
View File

@ -693,7 +693,7 @@ public class FSAppAttempt extends SchedulerApplicationAttempt
/**
* Reserve a spot for {@code container} on this {@code node}. If
* the container is {@code alreadyReserved} on the node, simply
* update relevant bookeeping. This dispatches ro relevant handlers
* update relevant bookkeeping. This dispatches ro relevant handlers
* in {@link FSSchedulerNode}..
* return whether reservation was possible with the current threshold limits
*/
@ -1393,12 +1393,12 @@ public class FSAppAttempt extends SchedulerApplicationAttempt
return;
}
StringBuilder diagnosticMessageBldr = new StringBuilder();
diagnosticMessageBldr.append(" (Resource request: ")
StringBuilder diagnosticMessage = new StringBuilder();
diagnosticMessage.append(" (Resource request: ")
.append(resource)
.append(reason);
updateAMContainerDiagnostics(AMState.INACTIVATED,
diagnosticMessageBldr.toString());
diagnosticMessage.toString());
}
/*

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/MaxRunningAppsEnforcer.java
View File

@ -146,7 +146,7 @@ public class MaxRunningAppsEnforcer {
/**
* This is called after reloading the allocation configuration when the
* scheduler is reinitilized
* scheduler is reinitialized
*
* Checks to see whether any non-runnable applications become runnable
* now that the max running apps of given queue has been changed

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/QueueManager.java
View File

@ -403,7 +403,7 @@ public class QueueManager {
// Ad hoc queues do not exist in the configured queues map
if (!configuredQueues.get(FSQueueType.LEAF).contains(child.getName()) &&
!configuredQueues.get(FSQueueType.PARENT).contains(child.getName())) {
// For ad hoc queues, set their max reource allocations based on
// For ad hoc queues, set their max resource allocations based on
// their parents' default child settings.
ConfigurableResource maxChild = parent.getMaxChildQueueResource();

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/VisitedResourceRequestTracker.java
View File

@ -77,11 +77,11 @@ class VisitedResourceRequestTracker {
private class TrackerPerPriorityResource {
private Set<String> racksWithNodesVisited = new HashSet<>();
private Set<String> racksVisted = new HashSet<>();
private Set<String> racksVisited = new HashSet<>();
private boolean anyVisited;
private boolean visitAny() {
if (racksVisted.isEmpty() && racksWithNodesVisited.isEmpty()) {
if (racksVisited.isEmpty() && racksWithNodesVisited.isEmpty()) {
anyVisited = true;
}
return anyVisited;
@ -91,13 +91,13 @@ class VisitedResourceRequestTracker {
if (anyVisited || racksWithNodesVisited.contains(rackName)) {
return false;
} else {
racksVisted.add(rackName);
racksVisited.add(rackName);
return true;
}
}
private boolean visitNode(String rackName) {
if (anyVisited || racksVisted.contains(rackName)) {
if (anyVisited || racksVisited.contains(rackName)) {
return false;
} else {
racksWithNodesVisited.add(rackName);

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/DominantResourceFairnessPolicy.java
View File

@ -147,7 +147,7 @@ public class DominantResourceFairnessPolicy extends SchedulingPolicy {
* @return &lt; 0, 0, or &gt; 0 if the first item is less than, equal to,
* or greater than the second item, respectively
*/
protected int compareAttribrutes(Schedulable s1, Schedulable s2) {
protected int compareAttributes(Schedulable s1, Schedulable s2) {
int res = (int) Math.signum(s1.getStartTime() - s2.getStartTime());
if (res == 0) {
@ -219,7 +219,7 @@ public class DominantResourceFairnessPolicy extends SchedulingPolicy {
}
if (res == 0) {
res = compareAttribrutes(s1, s2);
res = compareAttributes(s1, s2);
}
return res;
@ -423,7 +423,7 @@ public class DominantResourceFairnessPolicy extends SchedulingPolicy {
}
if (res == 0) {
res = compareAttribrutes(s1, s2);
res = compareAttributes(s1, s2);
}
return res;