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

YARN-9661:Fix typo in LocalityMulticastAMRMProxyPolicy.java and AbstractConfigurableFederationPolicy.java (#1042)

This commit is contained in:
hunshenshi 2019-07-02 01:46:33 +08:00 committed by Inigo Goiri
parent 1f75660350
commit b1dafc3506
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/AbstractConfigurableFederationPolicy.java
View File

@ -83,7 +83,7 @@ public abstract class AbstractConfigurableFederationPolicy
/** /**
* Returns true whether the last reinitialization requires actual changes, or * Returns true whether the last reinitialization requires actual changes, or
* was "free" as the weights have not changed. This is used by subclasses * was "free" as the weights have not changed. This is used by subclasses
* overriding reinitialize and calling super.reinitialize() to know wheter to * overriding reinitialize and calling super.reinitialize() to know whether to
* quit early. * quit early.
* *
* @return whether more work is needed to initialize. * @return whether more work is needed to initialize.

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/amrmproxy/LocalityMulticastAMRMProxyPolicy.java
View File

@ -68,7 +68,7 @@ import com.google.common.base.Preconditions;
* <p> * <p>
* Rack localized {@link ResourceRequest}s are forwarded to the RMs that owns * Rack localized {@link ResourceRequest}s are forwarded to the RMs that owns
* the corresponding rack. Note that in some deployments each rack could be * the corresponding rack. Note that in some deployments each rack could be
* striped across multiple RMs. Thsi policy respects that. If the * striped across multiple RMs. This policy respects that. If the
* {@link SubClusterResolver} cannot resolve this rack we default to forwarding * {@link SubClusterResolver} cannot resolve this rack we default to forwarding
* the {@link ResourceRequest} to the home sub-cluster. * the {@link ResourceRequest} to the home sub-cluster.
* </p> * </p>
@ -463,7 +463,7 @@ public class LocalityMulticastAMRMProxyPolicy extends AbstractAMRMProxyPolicy {
float headroomWeighting = float headroomWeighting =
1 / (float) allocationBookkeeper.getActiveAndEnabledSC().size(); 1 / (float) allocationBookkeeper.getActiveAndEnabledSC().size();
// if we have headroom infomration for this sub-cluster (and we are safe // if we have headroom information for this sub-cluster (and we are safe
// from /0 issues) // from /0 issues)
if (headroom.containsKey(targetId) if (headroom.containsKey(targetId)
&& allocationBookkeeper.totHeadroomMemory > 0) { && allocationBookkeeper.totHeadroomMemory > 0) {
@ -604,7 +604,7 @@ public class LocalityMulticastAMRMProxyPolicy extends AbstractAMRMProxyPolicy {
} }
/** /**
* Add a rack-local request to the final asnwer. * Add a rack-local request to the final answer.
*/ */
private void addRackRR(SubClusterId targetId, ResourceRequest rr) { private void addRackRR(SubClusterId targetId, ResourceRequest rr) {
Preconditions Preconditions