CapacityScheduler

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total6,262 of 6,2620%608 of 6080%4454451,5451,545132132
addApplication(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean)3490%180%1010535311
handle(SchedulerEvent)2970%270%232310410411
addApplicationOnRecovery(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean)1900%100%66292911
createResourceCommitRequest(CSAssignment)1790%320%1717565611
schedule(CapacityScheduler)1770%340%1818525211
moveApplication(ApplicationId, String)1750%120%77383811
allocate(ApplicationAttemptId, List, List, List, List, List, ContainerUpdates)1590%240%1313393911
checkAndGetApplicationLifetime(String, long, RMAppImpl)1490%160%99323211
doneApplicationAttempt(ApplicationAttemptId, RMAppAttemptState, boolean)1480%160%99313111
initScheduler(Configuration)1330%n/a11292911
reinitialize(Configuration, RMContext, boolean)1300%40%33303011
updateApplicationPriority(Priority, ApplicationId, SettableFuture, UserGroupInformation)1290%40%33272711
allocateFromReservedContainer(FiCaSchedulerNode, boolean, RMContainer)1270%100%66323211
resolveReservationQueueName(String, ApplicationId, ReservationId, boolean)1230%140%88232311
removeNode(RMNode)1170%80%55292911
addApplicationAttempt(ApplicationAttemptId, boolean, boolean)1150%60%44262611
allocateOrReserveNewContainers(CandidateNodeSet, boolean)1150%100%66313111
checkAndGetApplicationPriority(Priority, UserGroupInformation, String, ApplicationId)1100%80%55191911
removeQueue(CSQueue)1080%100%66191911
allocateContainerOnSingleNode(CandidateNodeSet, FiCaSchedulerNode, boolean)1070%60%44242411
tryCommit(Resource, ResourceCommitRequest, boolean)1050%200%1111353511
updateSchedulerHealth(long, NodeId, CSAssignment)1030%60%44252511
createResourceCommitRequest(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)1000%60%44262611
updatePlacementRules()980%140%88303011
handleQueueCreationError(ApplicationId, String, String, boolean, Exception)980%40%33121211
addNode(RMNode)890%100%66202011
setEntitlement(String, QueueEntitlement)880%60%44171711
getOrCreateQueueFromPlacementContext(ApplicationId, String, String, ApplicationPlacementContext, boolean)870%120%77232311
allocateContainersToNode(NodeId, boolean)840%220%1212262611
preValidateMoveApplication(ApplicationId, String)840%60%44222211
completedContainerInternal(RMContainer, ContainerStatus, RMContainerEventType)810%40%33171711
updateLabelsOnNode(NodeId, Set)800%100%66222211
moveReservedContainer(RMContainer, FiCaSchedulerNode)770%80%55222211
getMaximumResourceCapability(String)720%100%66151511
allocateContainersToNode(CandidateNodeSet, boolean)700%120%77202011
attemptAllocationOnNode(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode)690%80%55191911
updateNodeLabelsAndQueueResource(NodeLabelsUpdateSchedulerEvent)670%40%33171711
checkQueuePartition(FiCaSchedulerApp, AbstractLeafQueue)670%80%55151511
getSchedulerContainersToRelease(CSAssignment)670%180%1010202011
shouldSkipNodeSchedule(FiCaSchedulerNode, CapacityScheduler, boolean)650%120%77111111
printSchedulerInitialized()600%n/a11111111
doneApplication(ApplicationId, RMAppState)580%40%33141411
markContainerForKillable(RMContainer)570%40%33161611
checkAccess(UserGroupInformation, QueueACL, String)490%80%55141411
markContainerForNonKillable(RMContainer)450%20%22131311
getSchedulerContainer(RMContainer, boolean)450%80%55131311
nodeUpdate(RMNode)440%20%22131311
getQueueInfo(String, boolean, boolean)430%40%337711
getMaximumApplicationLifetime(String)390%40%337711
getCsConfProvider(Configuration)370%30%335511
updateNodeAttributes(NodeAttributesUpdateSchedulerEvent)370%20%22101011
canAllocateMore(CSAssignment, int, int)360%140%888811
getAddedAppQueueName(AppAddedSchedulerEvent)340%60%44101011
normalizeSchedulingRequests(List)330%80%55101011
getNodesHeartbeated(String)330%60%44111111
refreshLabelToNodeCache(Set)300%40%339911
getPlanQueues()300%40%336611
CapacityScheduler()280%n/a117711
allocateContainersOnMultiNodes(CandidateNodeSet)280%40%336611
markContainerForPreemption(ApplicationAttemptId, RMContainer)280%20%225511
getCandidateNodeSet(FiCaSchedulerNode)270%40%339911
initResourceCalculator()260%40%336611
isPrintSkippedNodeLogging(CapacityScheduler)260%60%446611
initializeQueues(CapacitySchedulerConfiguration)250%n/a118811
submitResourceCommitRequest(Resource, CSAssignment)250%40%338811
serviceStop()220%20%228811
updateNodeAndQueueResource(RMNode, ResourceOption)220%n/a116611
addNodes(List)220%20%226611
reinitializeQueues(CapacitySchedulerConfiguration)200%n/a116611
handleMoveToPlanQueue(String)200%40%334411
initMultiNodePlacement()190%20%225511
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
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
getDefaultReservationQueueName(String)90%n/a111111
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
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