Skip to content

Commit 7865582

Browse files
committed
YARN-10392: Fix typos Cotext related to AMRMProxyApplicationContext
1 parent a2610e2 commit 7865582

File tree

6 files changed

+11
-11
lines changed

6 files changed

+11
-11
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public interface AMRMProxyApplicationContext {
6767
* Gets the NMContext object.
6868
* @return the NMContext.
6969
*/
70-
Context getNMCotext();
70+
Context getNMContext();
7171

7272
/**
7373
* Gets the credentials of this application.

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContextImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ public synchronized int getLocalAMRMTokenKeyId() {
144144
}
145145

146146
@Override
147-
public Context getNMCotext() {
147+
public Context getNMContext() {
148148
return nmContext;
149149
}
150150

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AbstractRequestInterceptor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,9 +159,9 @@ public DistributedSchedulingAllocateResponse allocateForDistributedScheduling(
159159
* @return the NMSS instance
160160
*/
161161
public NMStateStoreService getNMStateStore() {
162-
if (this.appContext == null || this.appContext.getNMCotext() == null) {
162+
if (this.appContext == null || this.appContext.getNMContext() == null) {
163163
return null;
164164
}
165-
return this.appContext.getNMCotext().getNMStateStore();
165+
return this.appContext.getNMContext().getNMStateStore();
166166
}
167167
}

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/DefaultRequestInterceptor.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ public void init(AMRMProxyApplicationContext appContext) {
9595
private ApplicationMasterProtocol createRMClient(
9696
AMRMProxyApplicationContext appContext, final Configuration conf)
9797
throws IOException, InterruptedException {
98-
if (appContext.getNMCotext().isDistributedSchedulingEnabled()) {
98+
if (appContext.getNMContext().isDistributedSchedulingEnabled()) {
9999
return user.doAs(
100100
new PrivilegedExceptionAction<DistributedSchedulingAMProtocol>() {
101101
@Override
@@ -144,7 +144,7 @@ public AllocateResponse allocate(final AllocateRequest request)
144144
registerApplicationMasterForDistributedScheduling
145145
(RegisterApplicationMasterRequest request) throws YarnException,
146146
IOException {
147-
if (getApplicationContext().getNMCotext()
147+
if (getApplicationContext().getNMContext()
148148
.isDistributedSchedulingEnabled()) {
149149
LOG.info("Forwarding registerApplicationMasterForDistributedScheduling" +
150150
"request to the real YARN RM");
@@ -161,7 +161,7 @@ public DistributedSchedulingAllocateResponse allocateForDistributedScheduling(
161161
throws YarnException, IOException {
162162
LOG.debug("Forwarding allocateForDistributedScheduling request" +
163163
"to the real YARN RM");
164-
if (getApplicationContext().getNMCotext()
164+
if (getApplicationContext().getNMContext()
165165
.isDistributedSchedulingEnabled()) {
166166
DistributedSchedulingAllocateResponse allocateResponse =
167167
((DistributedSchedulingAMProtocol)rmClient)

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/scheduler/DistributedScheduler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,11 +87,11 @@ public final class DistributedScheduler extends AbstractRequestInterceptor {
8787

8888
public void init(AMRMProxyApplicationContext applicationContext) {
8989
super.init(applicationContext);
90-
initLocal(applicationContext.getNMCotext().getNodeStatusUpdater()
90+
initLocal(applicationContext.getNMContext().getNodeStatusUpdater()
9191
.getRMIdentifier(),
9292
applicationContext.getApplicationAttemptId(),
93-
applicationContext.getNMCotext().getContainerAllocator(),
94-
applicationContext.getNMCotext().getNMTokenSecretManager(),
93+
applicationContext.getNMContext().getContainerAllocator(),
94+
applicationContext.getNMContext().getNMTokenSecretManager(),
9595
applicationContext.getUser());
9696
}
9797

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMContextImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@
7474
* <ul>
7575
* <li>serviceContext : These services called as <b>Always On</b> services.
7676
* Services that need to run always irrespective of the HA state of the RM.</li>
77-
* <li>activeServiceCotext : Active services context. Services that need to run
77+
* <li>activeServiceContext : Active services context. Services that need to run
7878
* only on the Active RM.</li>
7979
* </ul>
8080
* <p>

0 commit comments

Comments
 (0)