org.apache.hadoop.yarn.server.nodemanager

Class NodeManager

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.server.nodemanager.NodeManager

All Implemented Interfaces:

Closeable, AutoCloseable, Service, EventHandler<NodeManagerEvent>

public class NodeManager
extends CompositeService
implements EventHandler<NodeManagerEvent>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodeManager.NMContext

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
protected NodeManagerMetrics	metrics
static int	SHUTDOWN_HOOK_PRIORITY Priority of the NodeManager shutdown hook.

Fields inherited from class org.apache.hadoop.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Constructor and Description
NodeManager()

Method Summary

Methods

Modifier and Type	Method and Description
protected ContainerManagerImpl	createContainerManager(Context context, ContainerExecutor exec, DeletionService del, NodeStatusUpdater nodeStatusUpdater, ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected DeletionService	createDeletionService(ContainerExecutor exec)
protected NodeManager.NMContext	createNMContext(NMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInNM nmTokenSecretManager)
protected NodeResourceMonitor	createNodeResourceMonitor()
protected NodeStatusUpdater	createNodeStatusUpdater(Context context, Dispatcher dispatcher, NodeHealthCheckerService healthChecker)
protected WebServer	createWebServer(Context nmContext, ResourceView resourceView, ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected void	doSecureLogin()
String	getName() Get the name of this service.
Context	getNMContext()
NodeHealthCheckerService	getNodeHealthChecker()
NodeStatusUpdater	getNodeStatusUpdater()
void	handle(NodeManagerEvent event)
static void	main(String[] args)
protected void	resyncWithRM()
protected void	serviceInit(Configuration conf) All initialization code needed by a service.
protected void	serviceStart() Actions called during the INITED to STARTED transition.
protected void	serviceStop() Actions called during the transition to the STOPPED state.
protected void	shutDown()

Methods inherited from class org.apache.hadoop.service.CompositeService

addIfService, addService, getServices, removeService

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Field Detail

SHUTDOWN_HOOK_PRIORITY

public static final int SHUTDOWN_HOOK_PRIORITY

Priority of the NodeManager shutdown hook.

See Also:

Constant Field Values

metrics

protected final NodeManagerMetrics metrics

Constructor Detail

NodeManager

public NodeManager()

Method Detail

createNodeStatusUpdater

protected NodeStatusUpdater createNodeStatusUpdater(Context context,
                                        Dispatcher dispatcher,
                                        NodeHealthCheckerService healthChecker)

createNodeResourceMonitor

protected NodeResourceMonitor createNodeResourceMonitor()

createContainerManager

protected ContainerManagerImpl createContainerManager(Context context,
                                          ContainerExecutor exec,
                                          DeletionService del,
                                          NodeStatusUpdater nodeStatusUpdater,
                                          ApplicationACLsManager aclsManager,
                                          LocalDirsHandlerService dirsHandler)

createWebServer

protected WebServer createWebServer(Context nmContext,
                        ResourceView resourceView,
                        ApplicationACLsManager aclsManager,
                        LocalDirsHandlerService dirsHandler)

createDeletionService

protected DeletionService createDeletionService(ContainerExecutor exec)

createNMContext

protected NodeManager.NMContext createNMContext(NMContainerTokenSecretManager containerTokenSecretManager,
                                    NMTokenSecretManagerInNM nmTokenSecretManager)

doSecureLogin

protected void doSecureLogin()
                      throws IOException

Throws:

IOException

serviceInit

protected void serviceInit(Configuration conf)
                    throws Exception

Description copied from class: AbstractService

All initialization code needed by a service. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.init(Configuration) prevents re-entrancy. The base implementation checks to see if the subclass has created a new configuration instance, and if so, updates the base class value

Overrides:

serviceInit in class CompositeService

Parameters:

conf - configuration

Throws:

Exception - on a failure -these will be caught, possibly wrapped, and wil; trigger a service stop

serviceStart

protected void serviceStart()
                     throws Exception

Description copied from class: AbstractService

Actions called during the INITED to STARTED transition. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.start() prevents re-entrancy.

Overrides:

serviceStart in class CompositeService

Throws:

Exception - if needed -these will be caught, wrapped, and trigger a service stop

serviceStop

protected void serviceStop()
                    throws Exception

Description copied from class: AbstractService

Actions called during the transition to the STOPPED state. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.stop() prevents re-entrancy. Implementations MUST write this to be robust against failures, including checks for null references -and for the first failure to not stop other attempts to shut down parts of the service.

Overrides:

serviceStop in class CompositeService

Throws:

Exception - if needed -these will be caught and logged.

getName

public String getName()

Description copied from interface: Service

Get the name of this service.

Specified by:

getName in interface Service

Overrides:

getName in class AbstractService

Returns:

the service name

shutDown

protected void shutDown()

resyncWithRM

protected void resyncWithRM()

getNodeHealthChecker

public NodeHealthCheckerService getNodeHealthChecker()

Returns:

the node health checker

handle

public void handle(NodeManagerEvent event)

Specified by:

handle in interface EventHandler<NodeManagerEvent>

getNMContext

public Context getNMContext()

main

public static void main(String[] args)

getNodeStatusUpdater

@InterfaceAudience.Private
public NodeStatusUpdater getNodeStatusUpdater()