public class ContainerManagerImpl extends org.apache.hadoop.service.CompositeService implements org.apache.hadoop.service.ServiceStateChangeListener, org.apache.hadoop.yarn.api.ContainerManagementProtocol, org.apache.hadoop.yarn.event.EventHandler<ContainerManagerEvent>
Modifier and Type | Field and Description |
---|---|
protected LocalDirsHandlerService |
dirsHandler |
protected org.apache.hadoop.yarn.event.AsyncDispatcher |
dispatcher |
Constructor and Description |
---|
ContainerManagerImpl(Context context,
ContainerExecutor exec,
DeletionService deletionContext,
NodeStatusUpdater nodeStatusUpdater,
NodeManagerMetrics metrics,
org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager,
LocalDirsHandlerService dirsHandler) |
Modifier and Type | Method and Description |
---|---|
protected void |
authorizeGetAndStopContainerRequest(org.apache.hadoop.yarn.api.records.ContainerId containerId,
Container container,
boolean stopRequest,
org.apache.hadoop.yarn.security.NMTokenIdentifier identifier) |
protected void |
authorizeStartRequest(org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier,
org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier) |
protected void |
authorizeUser(org.apache.hadoop.security.UserGroupInformation remoteUgi,
org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier) |
void |
cleanUpApplicationsOnNMShutDown() |
void |
cleanupContainersOnNMResync() |
protected ContainersLauncher |
createContainersLauncher(Context context,
ContainerExecutor exec) |
protected LogHandler |
createLogHandler(org.apache.hadoop.conf.Configuration conf,
Context context,
DeletionService deletionService) |
protected ResourceLocalizationService |
createResourceLocalizationService(ContainerExecutor exec,
DeletionService deletionContext,
Context context) |
protected SharedCacheUploadService |
createSharedCacheUploaderService() |
Map<String,ByteBuffer> |
getAuxServiceMetaData() |
Map<String,ByteBuffer> |
getAuxServiceMetaData(org.apache.hadoop.yarn.api.records.ContainerId cId) |
boolean |
getBlockNewContainerRequestsStatus() |
ContainersMonitor |
getContainersMonitor() |
org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesResponse |
getContainerStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesRequest request)
Get a list of container statuses running on this NodeManager
|
Context |
getContext() |
protected org.apache.hadoop.security.UserGroupInformation |
getRemoteUgi() |
void |
handle(ContainerManagerEvent event) |
protected org.apache.hadoop.yarn.security.NMTokenIdentifier |
selectNMTokenIdentifier(org.apache.hadoop.security.UserGroupInformation remoteUgi) |
void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
void |
serviceStop() |
void |
setBlockNewContainerRequests(boolean blockNewContainerRequests) |
org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse |
startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest requests)
Start a list of containers on this NodeManager.
|
void |
stateChanged(org.apache.hadoop.service.Service service) |
org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse |
stopContainers(org.apache.hadoop.yarn.api.protocolrecords.StopContainersRequest requests)
Stop a list of containers running on this NodeManager.
|
protected void |
updateNMTokenIdentifier(org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier) |
protected org.apache.hadoop.yarn.security.ContainerTokenIdentifier |
verifyAndGetContainerTokenIdentifier(org.apache.hadoop.yarn.api.records.Token token,
org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier) |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected LocalDirsHandlerService dirsHandler
protected final org.apache.hadoop.yarn.event.AsyncDispatcher dispatcher
public ContainerManagerImpl(Context context, ContainerExecutor exec, DeletionService deletionContext, NodeStatusUpdater nodeStatusUpdater, NodeManagerMetrics metrics, org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected LogHandler createLogHandler(org.apache.hadoop.conf.Configuration conf, Context context, DeletionService deletionService)
public ContainersMonitor getContainersMonitor()
protected ResourceLocalizationService createResourceLocalizationService(ContainerExecutor exec, DeletionService deletionContext, Context context)
protected SharedCacheUploadService createSharedCacheUploaderService()
protected ContainersLauncher createContainersLauncher(Context context, ContainerExecutor exec)
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public void cleanUpApplicationsOnNMShutDown()
public void cleanupContainersOnNMResync()
protected org.apache.hadoop.security.UserGroupInformation getRemoteUgi() throws org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.yarn.exceptions.YarnException
@InterfaceAudience.Private protected org.apache.hadoop.yarn.security.NMTokenIdentifier selectNMTokenIdentifier(org.apache.hadoop.security.UserGroupInformation remoteUgi)
protected void authorizeUser(org.apache.hadoop.security.UserGroupInformation remoteUgi, org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier) throws org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.yarn.exceptions.YarnException
@InterfaceAudience.Private protected void authorizeStartRequest(org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier, org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier) throws org.apache.hadoop.yarn.exceptions.YarnException
containerTokenIdentifier
- of the container to be startedorg.apache.hadoop.yarn.exceptions.YarnException
public org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest requests) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
startContainers
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
protected org.apache.hadoop.yarn.security.ContainerTokenIdentifier verifyAndGetContainerTokenIdentifier(org.apache.hadoop.yarn.api.records.Token token, org.apache.hadoop.yarn.security.ContainerTokenIdentifier containerTokenIdentifier) throws org.apache.hadoop.yarn.exceptions.YarnException, org.apache.hadoop.security.token.SecretManager.InvalidToken
org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.security.token.SecretManager.InvalidToken
@InterfaceAudience.Private protected void updateNMTokenIdentifier(org.apache.hadoop.yarn.security.NMTokenIdentifier nmTokenIdentifier) throws org.apache.hadoop.security.token.SecretManager.InvalidToken
org.apache.hadoop.security.token.SecretManager.InvalidToken
public org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse stopContainers(org.apache.hadoop.yarn.api.protocolrecords.StopContainersRequest requests) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
stopContainers
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesResponse getContainerStatuses(org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getContainerStatuses
in interface org.apache.hadoop.yarn.api.ContainerManagementProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
@InterfaceAudience.Private protected void authorizeGetAndStopContainerRequest(org.apache.hadoop.yarn.api.records.ContainerId containerId, Container container, boolean stopRequest, org.apache.hadoop.yarn.security.NMTokenIdentifier identifier) throws org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.yarn.exceptions.YarnException
public void handle(ContainerManagerEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ContainerManagerEvent>
public void setBlockNewContainerRequests(boolean blockNewContainerRequests)
@InterfaceAudience.Private public boolean getBlockNewContainerRequestsStatus()
public void stateChanged(org.apache.hadoop.service.Service service)
stateChanged
in interface org.apache.hadoop.service.ServiceStateChangeListener
public Context getContext()
public Map<String,ByteBuffer> getAuxServiceMetaData()
public Map<String,ByteBuffer> getAuxServiceMetaData(org.apache.hadoop.yarn.api.records.ContainerId cId)
Copyright © 2018 Apache Software Foundation. All Rights Reserved.