This is an automated email from the ASF dual-hosted git repository.
slfan1989 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 80a22a736ee8 YARN-11500. [Addendum] Fix typos in
hadoop-yarn-server-common#federation. (#6212) Contributed by Shilun Fan.
80a22a736ee8 is described below
commit 80a22a736ee886d78ef809bc06aa27f1dff837cb
Author: slfan1989 <55643692+slfan1...@users.noreply.github.com>
AuthorDate: Tue Oct 24 09:28:05 2023 +0800
YARN-11500. [Addendum] Fix typos in hadoop-yarn-server-common#federation.
(#6212) Contributed by Shilun Fan.
Reviewed-by: Inigo Goiri <inigo...@apache.org>
Signed-off-by: Shilun Fan <slfan1...@apache.org>
---
.../federation/policies/AbstractConfigurableFederationPolicy.java | 2 +-
.../policies/FederationPolicyInitializationContextValidator.java | 8 ++++----
.../federation/policies/amrmproxy/BroadcastAMRMProxyPolicy.java | 2 +-
.../policies/amrmproxy/LocalityMulticastAMRMProxyPolicy.java | 2 +-
.../server/federation/policies/manager/AbstractPolicyManager.java | 8 ++++----
.../federation/policies/manager/FederationPolicyManager.java | 4 ++--
6 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/AbstractConfigurableFederationPolicy.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/AbstractConfigurableFederationPolicy.java
index 7234d46b6126..c70b7b5eb543 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/AbstractConfigurableFederationPolicy.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/AbstractConfigurableFederationPolicy.java
@@ -53,7 +53,7 @@ public abstract class AbstractConfigurableFederationPolicy
initializationContext.getSubClusterPolicyConfiguration().getParams());
// if nothing has changed skip the rest of initialization
- // and signal to childs that the reinit is free via isDirty var.
+ // and signal to children that the reinit is free via isDirty var.
if (policyInfo != null && policyInfo.equals(newPolicyInfo)) {
isDirty = false;
return;
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/FederationPolicyInitializationContextValidator.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/FederationPolicyInitializationContextValidator.java
index da63bc1de468..1d430751036a 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/FederationPolicyInitializationContextValidator.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/FederationPolicyInitializationContextValidator.java
@@ -40,25 +40,25 @@ public final class
FederationPolicyInitializationContextValidator {
if (policyContext == null) {
throw new FederationPolicyInitializationException(
"The FederationPolicyInitializationContext provided is null. Cannot"
- + " reinitalize " + "successfully.");
+ + " reinitialize " + "successfully.");
}
if (policyContext.getFederationStateStoreFacade() == null) {
throw new FederationPolicyInitializationException(
"The FederationStateStoreFacade provided is null. Cannot"
- + " reinitalize successfully.");
+ + " reinitialize successfully.");
}
if (policyContext.getFederationSubclusterResolver() == null) {
throw new FederationPolicyInitializationException(
"The FederationSubclusterResolver provided is null. Cannot"
- + " reinitalize successfully.");
+ + " reinitialize successfully.");
}
if (policyContext.getSubClusterPolicyConfiguration() == null) {
throw new FederationPolicyInitializationException(
"The SubClusterPolicyConfiguration provided is null. Cannot "
- + "reinitalize successfully.");
+ + "reinitialize successfully.");
}
String intendedType =
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/amrmproxy/BroadcastAMRMProxyPolicy.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/amrmproxy/BroadcastAMRMProxyPolicy.java
index 643bfa6da011..36074f989fd1 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/amrmproxy/BroadcastAMRMProxyPolicy.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/amrmproxy/BroadcastAMRMProxyPolicy.java
@@ -41,7 +41,7 @@ public class BroadcastAMRMProxyPolicy extends
AbstractAMRMProxyPolicy {
public void reinitialize(
FederationPolicyInitializationContext policyContext)
throws FederationPolicyInitializationException {
- // overrides initialize to avoid weight checks that do no apply for
+ // overrides initialize to avoid weight checks that do not apply for
// this policy.
FederationPolicyInitializationContextValidator
.validate(policyContext, this.getClass().getCanonicalName());
diff --git
a/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
b/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
index a98ec138f604..2cd1eacaa665 100644
---
a/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
+++
b/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
@@ -394,7 +394,7 @@ public class LocalityMulticastAMRMProxyPolicy extends
AbstractAMRMProxyPolicy {
targetSubclusters = allocationBookkeeper.getActiveAndEnabledSC();
}
- // SECOND: pick how much to ask to each RM for each request
+ // SECOND: pick how much to ask each RM for each request
splitIndividualAny(resourceRequest, targetSubclusters,
allocationBookkeeper);
}
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/AbstractPolicyManager.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/AbstractPolicyManager.java
index f7a89c614fea..aa0742d090c2 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/AbstractPolicyManager.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/AbstractPolicyManager.java
@@ -53,10 +53,10 @@ public abstract class AbstractPolicyManager implements
* @param federationPolicyContext the current context
* @param oldInstance the existing (possibly null) instance.
*
- * @return a valid and fully reinitalized {@link FederationAMRMProxyPolicy}
+ * @return a valid and fully reinitialized {@link FederationAMRMProxyPolicy}
* instance
*
- * @throws FederationPolicyInitializationException if the reinitalization is
+ * @throws FederationPolicyInitializationException if the reinitialization is
* not valid, and ensure
* previous state is
preserved
*/
@@ -89,10 +89,10 @@ public abstract class AbstractPolicyManager implements
* @param federationPolicyContext the current context
* @param oldInstance the existing (possibly null) instance.
*
- * @return a valid and fully reinitalized {@link FederationRouterPolicy}
+ * @return a valid and fully reinitialized {@link FederationRouterPolicy}
* instance
*
- * @throws FederationPolicyInitializationException if the reinitalization is
+ * @throws FederationPolicyInitializationException if the reinitialization is
* not valid, and ensure
* previous state is
preserved
*/
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/FederationPolicyManager.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/FederationPolicyManager.java
index 23f7cf3ae38b..3aeb7d718e2d 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/FederationPolicyManager.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/federation/policies/manager/FederationPolicyManager.java
@@ -48,7 +48,7 @@ public interface FederationPolicyManager {
* instance of {@link FederationAMRMProxyPolicy} reinitialized with the
* current context, otherwise a new instance initialized with the current
* context is provided. If the instance is compatible with the current class
- * the implementors should attempt to reinitalize (retaining state). To
affect
+ * the implementors should attempt to reinitialize (retaining state). To
affect
* a complete policy reset oldInstance should be null.
*
* @param policyContext the current context
@@ -70,7 +70,7 @@ public interface FederationPolicyManager {
* instance of {@link FederationRouterPolicy} reinitialized with the current
* context, otherwise a new instance initialized with the current context is
* provided. If the instance is compatible with the current class the
- * implementors should attempt to reinitalize (retaining state). To affect a
+ * implementors should attempt to reinitialize (retaining state). To affect a
* complete policy reset oldInstance should be set to null.
*
* @param policyContext the current context
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
