Package org.apache.hadoop.yarn.server.resourcemanager.amlauncher

Class AMLauncher

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.amlauncher.AMLauncher

All Implemented Interfaces:

Runnable

public class AMLauncher
extends Object
implements Runnable

The launch of the AM itself.

Constructor Summary

Constructors

Constructor	Description
AMLauncher(RMContext rmContext, RMAppAttempt application, AMLauncherEventType eventType, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier>	createAndSetAMRMToken()
protected org.apache.hadoop.yarn.api.ContainerManagementProtocol	getContainerMgrProxy(org.apache.hadoop.yarn.api.records.ContainerId containerId)
protected org.apache.hadoop.yarn.ipc.YarnRPC	getYarnRPC()
protected void	onAMLaunchFailed(org.apache.hadoop.yarn.api.records.ContainerId containerId, Exception ie)
void	run()
protected void	setupTokens(org.apache.hadoop.yarn.api.records.ContainerLaunchContext container, org.apache.hadoop.yarn.api.records.ContainerId containerID)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMLauncher

public AMLauncher(RMContext rmContext,
 RMAppAttempt application,
 AMLauncherEventType eventType,
 org.apache.hadoop.conf.Configuration conf)

Method Details

getContainerMgrProxy

protected org.apache.hadoop.yarn.api.ContainerManagementProtocol getContainerMgrProxy(org.apache.hadoop.yarn.api.records.ContainerId containerId)

getYarnRPC

@VisibleForTesting
protected org.apache.hadoop.yarn.ipc.YarnRPC getYarnRPC()

setupTokens

@Private
@VisibleForTesting
protected void setupTokens(org.apache.hadoop.yarn.api.records.ContainerLaunchContext container,
 org.apache.hadoop.yarn.api.records.ContainerId containerID)
                    throws IOException

Throws:

IOException

createAndSetAMRMToken

@VisibleForTesting
protected org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier> createAndSetAMRMToken()

run

public void run()

Specified by:

run in interface Runnable

onAMLaunchFailed

protected void onAMLaunchFailed(org.apache.hadoop.yarn.api.records.ContainerId containerId,
 Exception ie)