AbstractYarnScheduler

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,529 of 2,5290%256 of 2560%2212217117119393
recoverContainersOnNode(List, RMNode)2040%340%1818595911
autoCorrectContainerAllocation(List, SchedulerApplicationAttempt)1970%220%1212474711
updateNewContainerInfo(RMNode, SchedulerNode)1580%220%1212404011
signalContainersIfOvercommitted(SchedulerNode, boolean)960%120%77262611
updateNodeResource(RMNode, ResourceOption)950%60%44202011
serviceInit(Configuration)880%40%33242411
nodeUpdate(RMNode)880%160%99282811
handleDecreaseRequests(SchedulerApplicationAttempt, List)840%100%66323211
completedContainer(RMContainer, ContainerStatus, RMContainerEventType)830%100%66212111
updateCompletedContainers(List, Resource, NodeId, SchedulerNode)800%120%77242411
getTransferredContainers(ApplicationAttemptId)650%80%55171711
handleContainerUpdates(SchedulerApplicationAttempt, ContainerUpdates)650%160%99212111
recoverAndCreateContainer(NMContainerStatus, RMNode, String)620%n/a11161611
createDecreasedRMContainer(SchedulerApplicationAttempt, UpdateContainerRequest, RMContainer)620%n/a11191911
rollbackContainerUpdate(ContainerId)550%60%44171711
releaseContainers(List, SchedulerApplicationAttempt)540%60%44121211
containerIncreasedOnNode(ContainerId, SchedulerNode, Container)530%40%33151511
moveAllApps(String, String)490%20%22121211
AbstractYarnScheduler(String)480%n/a11131311
handleIncreaseRequests(SchedulerApplicationAttempt, List)470%60%44151511
clearPendingContainerCache()450%60%44101011
containerLaunchedOnNode(ContainerId, SchedulerNode)410%20%22131311
completeOustandingUpdatesWhichAreReserved(RMContainer, ContainerStatus, RMContainerEventType)400%100%66141411
createSchedContainerChangeRequest(UpdateContainerRequest, boolean)380%40%339911
createDemotedRMContainer(SchedulerApplicationAttempt, OpportunisticContainerContext, RMContainer)380%n/a11121211
createSchedContainerChangeRequests(List, boolean)350%20%22111111
killAllAppsInQueue(String)330%20%227711
recoverResourceRequestForContainer(RMContainer)260%80%55111111
serviceStop()250%40%339911
normalizeResourceRequests(List, String)230%20%226611
static {...}220%n/a116611
killOrphanContainerOnNode(RMNode, NMContainerStatus)180%20%225511
setClusterMaxPriority(Configuration)180%n/a116611
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
getAppsFromQueue(String)140%20%224411
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
moveApplication(ApplicationId, String)80%n/a111111
preValidateMoveApplication(ApplicationId, String)80%n/a111111
removeQueue(String)80%n/a111111
addQueue(Queue)80%n/a111111
setEntitlement(String, QueueEntitlement)80%n/a111111
getPlanQueues()80%n/a111111
getMinimumAllocation()80%n/a113311
getMaximumAllocation()80%n/a113311
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()20%n/a111111
checkAndGetApplicationLifetime(String, long, RMAppImpl)20%n/a111111
getMaximumApplicationLifetime(String)20%n/a111111
attemptAllocationOnNode(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)20%n/a111111
update()0%n/a111111
resetSchedulerMetrics()0%n/a111111