startContainerInternal(ContainerTokenIdentifier, StartContainerRequest, String) |  | 0% |  | 0% | 12 | 12 | 68 | 68 | 1 | 1 |
handle(ContainerManagerEvent) |  | 0% |  | 0% | 18 | 18 | 66 | 66 | 1 | 1 |
ContainerManagerImpl(Context, ContainerExecutor, DeletionService, NodeStatusUpdater, NodeManagerMetrics, LocalDirsHandlerService) |  | 0% |  | 0% | 3 | 3 | 43 | 43 | 1 | 1 |
serviceStart() |  | 0% |  | 0% | 12 | 12 | 42 | 42 | 1 | 1 |
updateContainerInternal(ContainerId, ContainerTokenIdentifier) |  | 0% |  | 0% | 14 | 14 | 38 | 38 | 1 | 1 |
authorizeStartAndResourceIncreaseRequest(NMTokenIdentifier, ContainerTokenIdentifier, boolean) |  | 0% |  | 0% | 11 | 11 | 43 | 43 | 1 | 1 |
logContainerStatus(String, ContainerStatus) |  | 0% |  | 0% | 2 | 2 | 27 | 27 | 1 | 1 |
recoverApplication(YarnServerNodemanagerRecoveryProtos.ContainerManagerApplicationProto) |  | 0% |  | 0% | 4 | 4 | 32 | 32 | 1 | 1 |
startContainers(StartContainersRequest) |  | 0% |  | 0% | 6 | 6 | 35 | 35 | 1 | 1 |
recoverContainer(NMStateStoreService.RecoveredContainerState) |  | 0% |  | 0% | 5 | 5 | 33 | 33 | 1 | 1 |
createContainerManagerDispatcher() |  | 0% |  | 0% | 2 | 2 | 35 | 35 | 1 | 1 |
buildAppProto(ApplicationId, String, Credentials, Map, LogAggregationContext, ApplicationImpl.FlowContext) |  | 0% |  | 0% | 8 | 8 | 31 | 31 | 1 | 1 |
updateContainer(ContainerUpdateRequest) |  | 0% |  | 0% | 3 | 3 | 26 | 26 | 1 | 1 |
cleanupContainersOnNMResync() |  | 0% |  | 0% | 7 | 7 | 26 | 26 | 1 | 1 |
cleanUpApplicationsOnNMShutDown() |  | 0% |  | 0% | 8 | 8 | 25 | 25 | 1 | 1 |
recover() |  | 0% |  | 0% | 5 | 5 | 25 | 25 | 1 | 1 |
stopContainers(StopContainersRequest) |  | 0% |  | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
preReInitializeOrLocalizeCheck(ContainerId, ContainerManagerImpl.ReInitOp) |  | 0% |  | 0% | 6 | 6 | 17 | 17 | 1 | 1 |
serviceInit(Configuration) |  | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
getLocalizationStatuses(GetLocalizationStatusesRequest) |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
getContainerStatuses(GetContainerStatusesRequest) |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
waitForRecoveredContainers() |  | 0% |  | 0% | 6 | 6 | 16 | 16 | 1 | 1 |
stopContainerInternal(ContainerId, String) |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
authorizeGetAndStopContainerRequest(ContainerId, Container, boolean, NMTokenIdentifier, String) |  | 0% |  | 0% | 6 | 6 | 14 | 14 | 1 | 1 |
performContainerPreStartChecks(NMTokenIdentifier, StartContainerRequest, ContainerTokenIdentifier) |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
getFlowContext(ContainerLaunchContext, ApplicationId) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
reInitializeContainer(ContainerId, ContainerLaunchContext, boolean) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
getContainerStatusInternal(ContainerId, NMTokenIdentifier, String) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
localize(ResourceLocalizationRequest) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
createAMRMProxyService(Configuration) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
recoverActiveContainer(Application, ContainerLaunchContext, ContainerTokenIdentifier, NMStateStoreService.RecoveredContainerState) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
getLocalizationStatusesInternal(ContainerId, NMTokenIdentifier, String) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
internalSignalToContainer(SignalContainerRequest, String) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
serviceStop() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
createContainersLauncher(Context, ContainerExecutor) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
verifyAndGetContainerTokenIdentifier(Token, ContainerTokenIdentifier) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
rollbackLastReInitialization(ContainerId) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
createLogHandler(Configuration, Context, DeletionService) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
selectNMTokenIdentifier(UserGroupInformation) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
authorizeUser(UserGroupInformation, NMTokenIdentifier) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
commitLastReInitialization(ContainerId) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
buildNodeId(InetSocketAddress, String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getRemoteUgi() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
handleCredentialUpdate() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
createResourceLocalizationService(ContainerExecutor, DeletionService, Context, NodeManagerMetrics) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
increaseContainersResource(IncreaseContainersResourceRequest) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createNMTimelinePublisher(Context) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
reInitializeContainer(ReInitializeContainerRequest) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createContainerScheduler(Context) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createContainersMonitor(ContainerExecutor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
signalToContainer(SignalContainerRequest) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
restartContainer(ContainerId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
refreshServiceAcls(Configuration, PolicyProvider) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
updateNMTokenIdentifier(NMTokenIdentifier) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createApplicationEventDispatcher() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
updateQueuingLimit(ContainerQueuingLimit) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createSharedCacheUploaderService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAuxServiceMetaData() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setAMRMProxyService(AMRMProxyService) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getOpportunisticContainersStatus() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getContainersMonitor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAMRMProxyService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isServiceStopped() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContainerScheduler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceLocalizationService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDispatcher() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
stateChanged(Service) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |