getQueueName usages: SLSCapacityScheduler getRealQueueName ! needs investigation ProportionalCapacityPreemptionPolicy cloneQueues ! queue identification, getting from preemtableQueues, TempQueuePerPartition QueuePlacementRuleUtils validateQueueMappingUnderParentQueue ! parent queue name match, logging -> Investigate the usage of QueuePath UserGroupMappingPlacementRule validateQueueMapping ! parent queue name match, logging AbstractAutoCreatedLeafQueue logging AbstractCSQueue initializeQueueState exception message setMaxCapacity(float maximumCapacity) sanity checks, the queue name appears only in thrown exception setMaxCapacity(String nodeLabel, float maximumCapacity) sanity checks, the queue name appears only in thrown exception updateConfigurableResourceRequirement(String queuePath, Resource clusterResource) logging and exception message validateAbsoluteVsPercentageCapacityConfig(Resource minResource) exception message canAssignToThisQueue logging activeQueue exception message AbstractManagedParentQueue removeChildQueue logging AutoCreatedLeafQueue reinitialize leaf queue config query / queue identification CapacityScheduler addApplication queue identification / parent validation addApplicationAttempt logging allocateFromReservedContainer recordQueueActivity -> activityLogger seems generic / logging handle(SchedulerEvent event) logging markContainerForKillable preemption, it is used to create a KillableContainer markContainerForNonKillable preemption, it is used to create a KillableContainer checkQueuePartition(FiCaSchedulerApp app, LeafQueue dest) exception message doneApplication logging doneApplicationAttempt !!! queue identification / logging, USES Queue interface, which has NO getQueuePath allocateContainerOnSingleNode recordQueueActivity allocateContainersOnMultiNodes recordQueueActivity resolveReservationQueueName ! parent name check CapacitySchedulerQueueManager validateQueueHierarchy logging and getting a queue updateQueues checking queue existance setQueueAcls ? acl management, must be full name getQueueToLabels build queue -> label mapping LeafQueue setupQueueConfigs logging getQueueUserAclInfo ? creates and returns a userAclInfo calculateAndGetAMResourceLimitPerPartition logging activateApplications logging addApplicationAttempt logging removeApplicationAttempt logging assignContainers Activities logger canAssignToUser logging allocateResource logging releaseResource logging ManagedParentQueue reinitialize logging validateQueueManagementChanges logging addChildQueue exception message ParentQueue setChildQueues exception messages getUserAclInfo ? creates and returns a userAclInfo reinitialize logging addApplication logging removeApplication logging assignContainers logging Activities logger canAssign Activities logger assignContainersToChildQueues logging calculateEffectiveResourcesAndCapacity root checking... ?! BY NAME?! deriveCapacityFromAbsoluteConfigurations logging attachContainer logging detachContainer logging killContainersToEnforceMaxQueueCapacity logging apply logging getQueuesMap ! getQueueName -> queue mapping getParentName ! returns parent name -> needs investigation QueueManagementChange toString a to string implementation, probably safe to replace QueueManagementDynamicEditPolicy computeQueueManagementChanges logging UserManager computeUserLimit logging WorkflowPriorityMappingsManager mapWorkflowPriorityForApp ! logging and getting/checkign queue priority PreemptionManager refreshQueues ! multiple uses, queue identification -> needs investigation GuaranteedOrZeroCapacityOverTimePolicy init logging initializeLeafQueueTemplate logging and exception messages computeQueueManagementChanges logging updateLeafQueueState ! logging, adding to new queue hashset getSortedLeafQueues ! checks for leaf queue activity and adds to set which gets returned deactivateLeafQueuesIfInActive ! queue identification commitQueueManagementChanges logging reinitialize logging getLeafQueueState ! queue identification GuaranteedOrZeroCapacityOverTimePolicy.LeafQueueState createLeafQueueStateIfNotExists uses to add the queue to a partition -> queuename -> queue double map CapacitySchedulerInfo CapacitySchedulerInfo ! getting ACLs, providing external interface CapacitySchedulerQueueInfo CapacitySchedulerQueueInfo ! getting ACLs, providing external interface