diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java index 92afcb7ad12..f42940892d0 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java @@ -67,7 +67,7 @@ public interface AMRMProxyApplicationContext { * Gets the NMContext object. * @return the NMContext. */ - Context getNMCotext(); + Context getNMContext(); /** * Gets the credentials of this application. diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContextImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContextImpl.java index 8a0209507b4..d67c2f9ec5d 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContextImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContextImpl.java @@ -144,7 +144,7 @@ public class AMRMProxyApplicationContextImpl implements } @Override - public Context getNMCotext() { + public Context getNMContext() { return nmContext; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AbstractRequestInterceptor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AbstractRequestInterceptor.java index 93b42cb5e56..42f3cb6c03d 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AbstractRequestInterceptor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AbstractRequestInterceptor.java @@ -159,9 +159,9 @@ public abstract class AbstractRequestInterceptor implements * @return the NMSS instance */ public NMStateStoreService getNMStateStore() { - if (this.appContext == null || this.appContext.getNMCotext() == null) { + if (this.appContext == null || this.appContext.getNMContext() == null) { return null; } - return this.appContext.getNMCotext().getNMStateStore(); + return this.appContext.getNMContext().getNMStateStore(); } } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/DefaultRequestInterceptor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/DefaultRequestInterceptor.java index d6deca024e6..45af5e75f84 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/DefaultRequestInterceptor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/DefaultRequestInterceptor.java @@ -95,7 +95,7 @@ public final class DefaultRequestInterceptor extends private ApplicationMasterProtocol createRMClient( AMRMProxyApplicationContext appContext, final Configuration conf) throws IOException, InterruptedException { - if (appContext.getNMCotext().isDistributedSchedulingEnabled()) { + if (appContext.getNMContext().isDistributedSchedulingEnabled()) { return user.doAs( new PrivilegedExceptionAction() { @Override @@ -144,7 +144,7 @@ public final class DefaultRequestInterceptor extends registerApplicationMasterForDistributedScheduling (RegisterApplicationMasterRequest request) throws YarnException, IOException { - if (getApplicationContext().getNMCotext() + if (getApplicationContext().getNMContext() .isDistributedSchedulingEnabled()) { LOG.info("Forwarding registerApplicationMasterForDistributedScheduling" + "request to the real YARN RM"); @@ -161,7 +161,7 @@ public final class DefaultRequestInterceptor extends throws YarnException, IOException { LOG.debug("Forwarding allocateForDistributedScheduling request" + "to the real YARN RM"); - if (getApplicationContext().getNMCotext() + if (getApplicationContext().getNMContext() .isDistributedSchedulingEnabled()) { DistributedSchedulingAllocateResponse allocateResponse = ((DistributedSchedulingAMProtocol)rmClient) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/scheduler/DistributedScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/scheduler/DistributedScheduler.java index b4be05ad11f..80ecf8ef9fa 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/scheduler/DistributedScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/scheduler/DistributedScheduler.java @@ -87,11 +87,11 @@ public final class DistributedScheduler extends AbstractRequestInterceptor { public void init(AMRMProxyApplicationContext applicationContext) { super.init(applicationContext); - initLocal(applicationContext.getNMCotext().getNodeStatusUpdater() + initLocal(applicationContext.getNMContext().getNodeStatusUpdater() .getRMIdentifier(), applicationContext.getApplicationAttemptId(), - applicationContext.getNMCotext().getContainerAllocator(), - applicationContext.getNMCotext().getNMTokenSecretManager(), + applicationContext.getNMContext().getContainerAllocator(), + applicationContext.getNMContext().getNMTokenSecretManager(), applicationContext.getUser()); } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMContextImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMContextImpl.java index 54e0281f7e8..f74d0bab779 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMContextImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMContextImpl.java @@ -74,7 +74,7 @@ import org.apache.hadoop.yarn.webapp.util.WebAppUtils; * *