CapacityScheduler

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total5,501 of 5,5010%608 of 6080%4454451,5451,545132132
handle(SchedulerEvent)2770%270%232310410411
addApplication(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean)2340%180%1010535311
createResourceCommitRequest(CSAssignment)1790%320%1717565611
schedule(CapacityScheduler)1770%340%1818525211
moveApplication(ApplicationId, String)1550%120%77383811
allocate(ApplicationAttemptId, List, List, List, List, List, ContainerUpdates)1380%240%1313393911
initScheduler(Configuration)1330%n/a11292911
addApplicationOnRecovery(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean)1260%100%66292911
doneApplicationAttempt(ApplicationAttemptId, RMAppAttemptState, boolean)1190%160%99313111
allocateFromReservedContainer(FiCaSchedulerNode, boolean, RMContainer)1180%100%66323211
checkAndGetApplicationLifetime(String, long, RMAppImpl)1180%160%99323211
reinitialize(Configuration, RMContext, boolean)1120%40%33303011
allocateOrReserveNewContainers(CandidateNodeSet, boolean)1090%100%66313111
updateApplicationPriority(Priority, ApplicationId, SettableFuture, UserGroupInformation)1060%40%33272711
tryCommit(Resource, ResourceCommitRequest, boolean)1050%200%1111353511
updateSchedulerHealth(long, NodeId, CSAssignment)1030%60%44252511
removeNode(RMNode)1020%80%55292911
resolveReservationQueueName(String, ApplicationId, ReservationId, boolean)1020%140%88232311
createResourceCommitRequest(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)1000%60%44262611
updatePlacementRules()980%140%88303011
addApplicationAttempt(ApplicationAttemptId, boolean, boolean)950%60%44262611
allocateContainerOnSingleNode(CandidateNodeSet, FiCaSchedulerNode, boolean)930%60%44242411
allocateContainersToNode(NodeId, boolean)840%220%1212262611
addNode(RMNode)800%100%66202011
getOrCreateQueueFromPlacementContext(ApplicationId, String, String, ApplicationPlacementContext, boolean)790%120%77232311
checkAndGetApplicationPriority(Priority, UserGroupInformation, String, ApplicationId)770%80%55191911
moveReservedContainer(RMContainer, FiCaSchedulerNode)770%80%55222211
preValidateMoveApplication(ApplicationId, String)760%60%44222211
updateLabelsOnNode(NodeId, Set)710%100%66222211
allocateContainersToNode(CandidateNodeSet, boolean)700%120%77202011
removeQueue(CSQueue)700%100%66191911
updateNodeLabelsAndQueueResource(NodeLabelsUpdateSchedulerEvent)670%40%33171711
getSchedulerContainersToRelease(CSAssignment)670%180%1010202011
printSchedulerInitialized()600%n/a11111111
handleQueueCreationError(ApplicationId, String, String, boolean, Exception)590%40%33121211
setEntitlement(String, QueueEntitlement)580%60%44171711
attemptAllocationOnNode(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)580%80%55191911
completedContainerInternal(RMContainer, ContainerStatus, RMContainerEventType)570%40%33171711
markContainerForKillable(RMContainer)570%40%33161611
checkQueuePartition(FiCaSchedulerApp, AbstractLeafQueue)550%80%55151511
getMaximumResourceCapability(String)500%100%66151511
checkAccess(UserGroupInformation, QueueACL, String)490%80%55141411
shouldSkipNodeSchedule(FiCaSchedulerNode, CapacityScheduler, boolean)460%120%77111111
doneApplication(ApplicationId, RMAppState)460%40%33141411
markContainerForNonKillable(RMContainer)450%20%22131311
getSchedulerContainer(RMContainer, boolean)450%80%55131311
nodeUpdate(RMNode)440%20%22131311
updateNodeAttributes(NodeAttributesUpdateSchedulerEvent)370%20%22101011
canAllocateMore(CSAssignment, int, int)360%140%888811
normalizeSchedulingRequests(List)330%80%55101011
getNodesHeartbeated(String)330%60%44111111
getCsConfProvider(Configuration)310%30%335511
refreshLabelToNodeCache(Set)300%40%339911
getPlanQueues()300%40%336611
getQueueInfo(String, boolean, boolean)290%40%337711
CapacityScheduler()280%n/a117711
allocateContainersOnMultiNodes(CandidateNodeSet)280%40%336611
markContainerForPreemption(ApplicationAttemptId, RMContainer)280%20%225511
getCandidateNodeSet(FiCaSchedulerNode)270%40%339911
getAddedAppQueueName(AppAddedSchedulerEvent)270%60%44101011
isPrintSkippedNodeLogging(CapacityScheduler)260%60%446611
initializeQueues(CapacitySchedulerConfiguration)250%n/a118811
submitResourceCommitRequest(Resource, CSAssignment)250%40%338811
getMaximumApplicationLifetime(String)250%40%337711
serviceStop()220%20%228811
updateNodeAndQueueResource(RMNode, ResourceOption)220%n/a116611
addNodes(List)220%20%226611
reinitializeQueues(CapacitySchedulerConfiguration)200%n/a116611
initMultiNodePlacement()190%20%225511
initResourceCalculator()180%40%336611
serviceInit(Configuration)180%n/a115511
getCSMappingPlacementRule()180%n/a115511
updateSchedulerNodeHBIntervalMetrics(NodeUpdateSchedulerEvent)180%20%227711
getCandidateNodeSet(String)170%20%226611
removeAutoCreatedQueue(CSQueue)170%40%336611
getAppsInQueue(String)170%20%226611
getQueueUserAclInfo()150%n/a116611
getSchedulingResourceTypes()150%20%224411
killReservedContainer(RMContainer)140%n/a115511
handleMoveToPlanQueue(String)140%40%334411
startSchedulerThreads()130%n/a115511
static {...}120%n/a115511
isSystemAppsLimitReached()110%20%224411
removeQueue(String)110%n/a114411
addQueue(Queue)110%n/a114411
normalizeQueueName(String)100%20%223311
initAsyncSchedulingProperties()90%n/a112211
getQueue(String)90%20%223311
getMutableConfProvider()90%20%223311
lambda$updateAttributesOnNode$2(Set, NodeId)90%n/a113311
lambda$getNodesHeartbeated$0(boolean, FiCaSchedulerNode)90%20%221111
lambda$getNodesHeartbeated$1(Map, FiCaSchedulerNode)70%n/a111111
reinitialize(Configuration, RMContext)60%n/a112211
updateAttributesOnNode(List, Set)60%n/a112211
getNode(NodeId)60%n/a111111
validateConf(Configuration)50%n/a113311
serviceStart()50%n/a113311
isAmbiguous(String)50%n/a111111
getApplicationAttempt(ApplicationAttemptId)50%n/a111111
setConf(Configuration)40%n/a112211
getRootQueueMetrics()40%n/a111111
getRootQueue()40%n/a111111
getContainerTokenSecretManager()40%n/a111111
setResourceCalculator(ResourceCalculator)40%n/a112211
getNumClusterNodes()40%n/a111111
setRMContext(RMContext)40%n/a112211
getAsyncScheduleInterval()40%n/a111111
setAsyncSchedulingConf(CapacityScheduler.AsyncSchedulingConfiguration)40%n/a112211
getAllNodes()40%n/a111111
killContainer(RMContainer)40%n/a112211
getClusterResourceUsage()40%n/a111111
getAsyncSchedulingPendingBacklogs()40%n/a111111
isConfigurationMutable()40%n/a111111
getNumAsyncSchedulerThreads()40%n/a111111
setMaxRunningAppsEnforcer(CSMaxRunningAppsEnforcer)40%n/a112211
setQueueManager(CapacitySchedulerQueueManager)40%n/a112211
getAsyncSchedulerThreads()40%n/a111111
getConf()30%n/a111111
getConfiguration()30%n/a111111
getQueueContext()30%n/a111111
getResourceCalculator()30%n/a111111
getRMContext()30%n/a111111
getDefaultReservationQueueName(String)30%n/a111111
getPreemptionManager()30%n/a111111
getCapacitySchedulerQueueManager()30%n/a111111
getWorkflowPriorityMappingsManager()30%n/a111111
getCsConfProvider()30%n/a111111
isMultiNodePlacementEnabled()30%n/a111111
getPendingApplicationComparator()30%n/a111111
resetSchedulerMetrics()0%n/a112211
placementConstraintEnabled()0%n/a111111
recover(RMStateStore.RMState)0%n/a111111