AbstractYarnScheduler

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,784 of 2,7840%256 of 2560%2212217127129393
recoverContainersOnNode(List, RMNode)2410%340%1818595911
autoCorrectContainerAllocation(List, SchedulerApplicationAttempt)1970%220%1212474711
updateNewContainerInfo(RMNode, SchedulerNode)1670%220%1212404011
updateNodeResource(RMNode, ResourceOption)1120%60%44202011
nodeUpdate(RMNode)970%160%99282811
signalContainersIfOvercommitted(SchedulerNode, boolean)960%120%77262611
completedContainer(RMContainer, ContainerStatus, RMContainerEventType)940%100%66212111
handleDecreaseRequests(SchedulerApplicationAttempt, List)920%100%66323211
serviceInit(Configuration)890%40%33242411
handleContainerUpdates(SchedulerApplicationAttempt, ContainerUpdates)890%160%99212111
updateCompletedContainers(List, Resource, NodeId, SchedulerNode)800%120%77242411
rollbackContainerUpdate(ContainerId)770%60%44171711
getTransferredContainers(ApplicationAttemptId)650%80%55171711
containerIncreasedOnNode(ContainerId, SchedulerNode, Container)650%40%33151511
recoverAndCreateContainer(NMContainerStatus, RMNode, String)620%n/a11161611
createDecreasedRMContainer(SchedulerApplicationAttempt, UpdateContainerRequest, RMContainer)620%n/a11191911
releaseContainers(List, SchedulerApplicationAttempt)600%60%44121211
handleIncreaseRequests(SchedulerApplicationAttempt, List)550%60%44151511
containerLaunchedOnNode(ContainerId, SchedulerNode)530%20%22131311
moveAllApps(String, String)490%20%22121211
AbstractYarnScheduler(String)480%n/a11131311
createSchedContainerChangeRequest(UpdateContainerRequest, boolean)470%40%33101011
clearPendingContainerCache()450%60%44101011
killAllAppsInQueue(String)410%20%227711
completeOustandingUpdatesWhichAreReserved(RMContainer, ContainerStatus, RMContainerEventType)400%100%66141411
createDemotedRMContainer(SchedulerApplicationAttempt, OpportunisticContainerContext, RMContainer)380%n/a11121211
createSchedContainerChangeRequests(List, boolean)350%20%22111111
recoverResourceRequestForContainer(RMContainer)260%80%55111111
serviceStop()250%40%339911
setClusterMaxPriority(Configuration)240%n/a116611
normalizeResourceRequests(List, String)230%20%226611
getAppsFromQueue(String)220%20%224411
static {...}220%n/a116611
killOrphanContainerOnNode(RMNode, NMContainerStatus)180%20%225511
serviceStart()170%40%337711
getSchedulerAppInfo(ApplicationAttemptId)170%20%225511
reinitialize(Configuration, RMContext)160%n/a116611
getAppResourceUsageReport(ApplicationAttemptId)150%20%225511
getApplicationAttempt(ApplicationAttemptId)140%20%223311
moveApplication(ApplicationId, String)140%n/a111111
preValidateMoveApplication(ApplicationId, String)140%n/a111111
removeQueue(String)140%n/a111111
addQueue(Queue)140%n/a111111
setEntitlement(String, QueueEntitlement)140%n/a111111
getPlanQueues()140%n/a111111
getMinimumAllocation()140%n/a113311
getMaximumAllocation()140%n/a113311
getRMContainer(ContainerId)120%20%223311
getPendingResourceRequestsForAttempt(ApplicationAttemptId)120%20%224411
getPendingSchedulingRequestsForAttempt(ApplicationAttemptId)120%20%224411
updateSchedulerHealthInformation(Resource, int)120%n/a113311
triggerUpdate()120%n/a114411
getBlacklistedNodes(SchedulerApplicationAttempt)110%n/a112211
createReleaseCache()110%n/a112211
getNormalizedResource(Resource, Resource)100%n/a114411
asyncContainerRelease(RMContainer)100%n/a112211
updateNodeResourceUtilization(RMNode, SchedulerNode)90%n/a114411
getMaxPriorityFromConf(Configuration)60%n/a111111
getNodes(NodeFilter)50%n/a111111
initMaximumResourceCapability(Resource)50%n/a112211
getCurrentAttemptForContainer(ContainerId)50%n/a111111
getNodeReport(NodeId)50%n/a111111
getSchedulerNode(NodeId)50%n/a111111
refreshMaximumAllocation(Resource)50%n/a112211
getNode(NodeId)50%n/a111111
normalizeResourceRequests(List)50%n/a112211
getNodeIds(String)50%n/a111111
getClusterResource()40%n/a111111
getMaximumResourceCapability()40%n/a111111
setLastNodeUpdateTime(long)40%n/a112211
setClock(Clock)40%n/a112211
lambda$autoCorrectContainerAllocation$0(AbstractYarnScheduler.ContainerObjectType)40%n/a111111
getNodeTracker()30%n/a111111
getSchedulingMonitorManager()30%n/a111111
getSchedulerApplications()30%n/a111111
shouldContainersBeAutoUpdated()30%n/a111111
getMinimumResourceCapability()30%n/a111111
getMaximumResourceCapability(String)30%n/a111111
getSchedulerHealth()30%n/a111111
getLastNodeUpdateTime()30%n/a111111
getSkipNodeInterval()30%n/a111111
getSchedulingResourceTypes()30%n/a111111
checkAndGetApplicationPriority(Priority, UserGroupInformation, String, ApplicationId)30%n/a111111
updateApplicationPriority(Priority, ApplicationId, SettableFuture, UserGroupInformation)30%n/a111111
getMaxClusterLevelAppPriority()30%n/a111111
getActivitiesManager()30%n/a111111
getClock()30%n/a111111
placementConstraintEnabled()0%n/a111111
checkAndGetApplicationLifetime(String, long, RMAppImpl)0%n/a111111
getMaximumApplicationLifetime(String)0%n/a111111
attemptAllocationOnNode(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)0%n/a111111
update()0%n/a111111
resetSchedulerMetrics()0%n/a111111