Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity

Class CapacitySchedulerConfigValidator

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfigValidator

public final class CapacitySchedulerConfigValidator
extends Object

Method Summary

Modifier and Type	Method	Description
static boolean	validateCSConfiguration(org.apache.hadoop.conf.Configuration oldConfParam, org.apache.hadoop.conf.Configuration newConf, RMContext rmContext)
static void	validateMemoryAllocation(org.apache.hadoop.conf.Configuration conf)
static Set<String>	validatePlacementRules(Collection<String> placementRuleStrs)
static void	validateQueueHierarchy(CSQueueStore queues, CSQueueStore newQueues, CapacitySchedulerConfiguration newConf)	Ensure all existing queues are present.
static void	validateVCores(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

validateCSConfiguration

public static boolean validateCSConfiguration(org.apache.hadoop.conf.Configuration oldConfParam,
 org.apache.hadoop.conf.Configuration newConf,
 RMContext rmContext)
                                       throws IOException

Throws:

IOException

validatePlacementRules

public static Set<String> validatePlacementRules(Collection<String> placementRuleStrs)
                                          throws IOException

Throws:

IOException

validateMemoryAllocation

public static void validateMemoryAllocation(org.apache.hadoop.conf.Configuration conf)

validateVCores

public static void validateVCores(org.apache.hadoop.conf.Configuration conf)

validateQueueHierarchy

public static void validateQueueHierarchy(CSQueueStore queues,
 CSQueueStore newQueues,
 CapacitySchedulerConfiguration newConf)
                                   throws IOException

Ensure all existing queues are present. Queues cannot be deleted if it's not in Stopped state, Queue's cannot be moved from one hierarchy to other also. Previous child queue could be converted into parent queue if it is in STOPPED state.

Parameters:

queues - existing queues

newQueues - new queues

newConf - Capacity Scheduler Configuration.

Throws:

IOException - an I/O exception has occurred.