public class NodeManager extends org.apache.hadoop.service.CompositeService implements org.apache.hadoop.yarn.event.EventHandler<NodeManagerEvent>
Modifier and Type | Class and Description |
---|---|
static class |
NodeManager.NMContext |
Modifier and Type | Field and Description |
---|---|
protected NodeManagerMetrics |
metrics |
static int |
SHUTDOWN_HOOK_PRIORITY
Priority of the NodeManager shutdown hook.
|
Constructor and Description |
---|
NodeManager() |
Modifier and Type | Method and Description |
---|---|
protected ContainerManagerImpl |
createContainerManager(Context context,
ContainerExecutor exec,
DeletionService del,
NodeStatusUpdater nodeStatusUpdater,
org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager,
LocalDirsHandlerService dirsHandler) |
protected DeletionService |
createDeletionService(ContainerExecutor exec) |
protected NodeManager.NMContext |
createNMContext(NMContainerTokenSecretManager containerTokenSecretManager,
NMTokenSecretManagerInNM nmTokenSecretManager,
NMStateStoreService stateStore) |
protected NodeLabelsProvider |
createNodeLabelsProvider(org.apache.hadoop.conf.Configuration conf) |
protected NodeResourceMonitor |
createNodeResourceMonitor() |
protected NodeStatusUpdater |
createNodeStatusUpdater(Context context,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
NodeHealthCheckerService healthChecker) |
protected NodeStatusUpdater |
createNodeStatusUpdater(Context context,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
NodeHealthCheckerService healthChecker,
NodeLabelsProvider nodeLabelsProvider) |
protected WebServer |
createWebServer(Context nmContext,
ResourceView resourceView,
org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager,
LocalDirsHandlerService dirsHandler) |
protected void |
doSecureLogin() |
String |
getName() |
Context |
getNMContext() |
static long |
getNMStartupTime() |
NodeHealthCheckerService |
getNodeHealthChecker() |
static org.apache.hadoop.util.NodeHealthScriptRunner |
getNodeHealthScriptRunner(org.apache.hadoop.conf.Configuration conf) |
NodeStatusUpdater |
getNodeStatusUpdater() |
void |
handle(NodeManagerEvent event) |
static void |
main(String[] args) |
protected void |
resyncWithRM() |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
protected void |
shutDown() |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final int SHUTDOWN_HOOK_PRIORITY
protected final NodeManagerMetrics metrics
public static long getNMStartupTime()
protected NodeStatusUpdater createNodeStatusUpdater(Context context, org.apache.hadoop.yarn.event.Dispatcher dispatcher, NodeHealthCheckerService healthChecker)
protected NodeStatusUpdater createNodeStatusUpdater(Context context, org.apache.hadoop.yarn.event.Dispatcher dispatcher, NodeHealthCheckerService healthChecker, NodeLabelsProvider nodeLabelsProvider)
protected NodeLabelsProvider createNodeLabelsProvider(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
protected NodeResourceMonitor createNodeResourceMonitor()
protected ContainerManagerImpl createContainerManager(Context context, ContainerExecutor exec, DeletionService del, NodeStatusUpdater nodeStatusUpdater, org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected WebServer createWebServer(Context nmContext, ResourceView resourceView, org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected DeletionService createDeletionService(ContainerExecutor exec)
protected NodeManager.NMContext createNMContext(NMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInNM nmTokenSecretManager, NMStateStoreService stateStore)
protected void doSecureLogin() throws IOException
IOException
public static org.apache.hadoop.util.NodeHealthScriptRunner getNodeHealthScriptRunner(org.apache.hadoop.conf.Configuration conf)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public String getName()
getName
in interface org.apache.hadoop.service.Service
getName
in class org.apache.hadoop.service.AbstractService
protected void shutDown()
protected void resyncWithRM()
public NodeHealthCheckerService getNodeHealthChecker()
public void handle(NodeManagerEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<NodeManagerEvent>
public Context getNMContext()
public static void main(String[] args) throws IOException
IOException
@InterfaceAudience.Private public NodeStatusUpdater getNodeStatusUpdater()
Copyright © 2018 Apache Software Foundation. All Rights Reserved.