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

YARN-10392: Fix typos Cotext related to AMRMProxyApplicationContext

This commit is contained in:
Sungpeo Kook 2020-08-07 09:41:54 +09:00
parent a2610e21ed
commit 786558259e
6 changed files with 11 additions and 11 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-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/amrmproxy/AMRMProxyApplicationContext.java
View File

@ -67,7 +67,7 @@ public interface AMRMProxyApplicationContext {
* Gets the NMContext object. * Gets the NMContext object.
* @return the NMContext. * @return the NMContext.
*/ */
Context getNMCotext(); Context getNMContext();
/** /**
* Gets the credentials of this application. * Gets the credentials of this application.

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

@ -144,7 +144,7 @@ public class AMRMProxyApplicationContextImpl implements
} }
@Override @Override
public Context getNMCotext() { public Context getNMContext() {
return nmContext; return nmContext;
} }

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

@ -159,9 +159,9 @@ public abstract class AbstractRequestInterceptor implements
* @return the NMSS instance * @return the NMSS instance
*/ */
public NMStateStoreService getNMStateStore() { public NMStateStoreService getNMStateStore() {
if (this.appContext == null || this.appContext.getNMCotext() == null) { if (this.appContext == null || this.appContext.getNMContext() == null) {
return null; return null;
} }
return this.appContext.getNMCotext().getNMStateStore(); return this.appContext.getNMContext().getNMStateStore();
} }
} }

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

@ -95,7 +95,7 @@ public final class DefaultRequestInterceptor extends
private ApplicationMasterProtocol createRMClient( private ApplicationMasterProtocol createRMClient(
AMRMProxyApplicationContext appContext, final Configuration conf) AMRMProxyApplicationContext appContext, final Configuration conf)
throws IOException, InterruptedException { throws IOException, InterruptedException {
if (appContext.getNMCotext().isDistributedSchedulingEnabled()) { if (appContext.getNMContext().isDistributedSchedulingEnabled()) {
return user.doAs( return user.doAs(
new PrivilegedExceptionAction<DistributedSchedulingAMProtocol>() { new PrivilegedExceptionAction<DistributedSchedulingAMProtocol>() {
@Override @Override
@ -144,7 +144,7 @@ public final class DefaultRequestInterceptor extends
registerApplicationMasterForDistributedScheduling registerApplicationMasterForDistributedScheduling
(RegisterApplicationMasterRequest request) throws YarnException, (RegisterApplicationMasterRequest request) throws YarnException,
IOException { IOException {
if (getApplicationContext().getNMCotext() if (getApplicationContext().getNMContext()
.isDistributedSchedulingEnabled()) { .isDistributedSchedulingEnabled()) {
LOG.info("Forwarding registerApplicationMasterForDistributedScheduling" + LOG.info("Forwarding registerApplicationMasterForDistributedScheduling" +
"request to the real YARN RM"); "request to the real YARN RM");
@ -161,7 +161,7 @@ public final class DefaultRequestInterceptor extends
throws YarnException, IOException { throws YarnException, IOException {
LOG.debug("Forwarding allocateForDistributedScheduling request" + LOG.debug("Forwarding allocateForDistributedScheduling request" +
"to the real YARN RM"); "to the real YARN RM");
if (getApplicationContext().getNMCotext() if (getApplicationContext().getNMContext()
.isDistributedSchedulingEnabled()) { .isDistributedSchedulingEnabled()) {
DistributedSchedulingAllocateResponse allocateResponse = DistributedSchedulingAllocateResponse allocateResponse =
((DistributedSchedulingAMProtocol)rmClient) ((DistributedSchedulingAMProtocol)rmClient)

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

@ -87,11 +87,11 @@ public final class DistributedScheduler extends AbstractRequestInterceptor {
public void init(AMRMProxyApplicationContext applicationContext) { public void init(AMRMProxyApplicationContext applicationContext) {
super.init(applicationContext); super.init(applicationContext);
initLocal(applicationContext.getNMCotext().getNodeStatusUpdater() initLocal(applicationContext.getNMContext().getNodeStatusUpdater()
.getRMIdentifier(), .getRMIdentifier(),
applicationContext.getApplicationAttemptId(), applicationContext.getApplicationAttemptId(),
applicationContext.getNMCotext().getContainerAllocator(), applicationContext.getNMContext().getContainerAllocator(),
applicationContext.getNMCotext().getNMTokenSecretManager(), applicationContext.getNMContext().getNMTokenSecretManager(),
applicationContext.getUser()); applicationContext.getUser());
} }

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

@ -74,7 +74,7 @@ import org.apache.hadoop.yarn.webapp.util.WebAppUtils;
* <ul> * <ul>
* <li>serviceContext : These services called as <b>Always On</b> services. * <li>serviceContext : These services called as <b>Always On</b> services.
* Services that need to run always irrespective of the HA state of the RM.</li> * Services that need to run always irrespective of the HA state of the RM.</li>
* <li>activeServiceCotext : Active services context. Services that need to run * <li>activeServiceContext : Active services context. Services that need to run
* only on the Active RM.</li> * only on the Active RM.</li>
* </ul> * </ul>
* <p> * <p>