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

Interface PreemptableResourceScheduler

All Superinterfaces:

org.apache.hadoop.yarn.event.EventHandler<SchedulerEvent>, Recoverable, ResourceScheduler, YarnScheduler

All Known Implementing Classes:

CapacityScheduler

public interface PreemptableResourceScheduler
extends ResourceScheduler

Interface for a scheduler that supports preemption/killing

Method Summary

Modifier and Type	Method	Description
void	killReservedContainer(RMContainer container)	If the scheduler support container reservations, this method is used to ask the scheduler to drop the reservation for the given container.
void	markContainerForKillable(RMContainer container)	Ask the scheduler to forcibly interrupt the container given as input.
void	markContainerForPreemption(org.apache.hadoop.yarn.api.records.ApplicationAttemptId aid, RMContainer container)	Ask the scheduler to obtain back the container from a specific application by issuing a preemption request

Methods inherited from interface org.apache.hadoop.yarn.event.EventHandler

handle

Methods inherited from interface org.apache.hadoop.yarn.server.resourcemanager.recovery.Recoverable

recover

Methods inherited from interface org.apache.hadoop.yarn.server.resourcemanager.scheduler.ResourceScheduler

attemptAllocationOnNode, getNodeIds, reinitialize, resetSchedulerMetrics, setRMContext

Methods inherited from interface org.apache.hadoop.yarn.server.resourcemanager.scheduler.YarnScheduler

addQueue, allocate, checkAccess, checkAndGetApplicationLifetime, checkAndGetApplicationPriority, getAppResourceUsageReport, getAppsInQueue, getClusterResource, getMaxClusterLevelAppPriority, getMaximumApplicationLifetime, getMaximumResourceCapability, getMaximumResourceCapability, getMinimumResourceCapability, getNodeReport, getNormalizedResource, getNumClusterNodes, getPendingResourceRequestsForAttempt, getPendingSchedulingRequestsForAttempt, getPlanQueues, getQueueInfo, getQueueUserAclInfo, getResourceCalculator, getRMContainer, getRootQueueMetrics, getSchedulerAppInfo, getSchedulerNode, getSchedulingResourceTypes, getTransferredContainers, killAllAppsInQueue, moveAllApps, moveApplication, preValidateMoveApplication, removeQueue, setClusterMaxPriority, setEntitlement, updateApplicationPriority

Method Details

killReservedContainer

void killReservedContainer(RMContainer container)

If the scheduler support container reservations, this method is used to ask the scheduler to drop the reservation for the given container.

Parameters:

container - Reference to reserved container allocation.

markContainerForPreemption

void markContainerForPreemption(org.apache.hadoop.yarn.api.records.ApplicationAttemptId aid,
 RMContainer container)

Ask the scheduler to obtain back the container from a specific application by issuing a preemption request

Parameters:

aid - the application from which we want to get a container back

container - the container we want back

markContainerForKillable

void markContainerForKillable(RMContainer container)

Ask the scheduler to forcibly interrupt the container given as input.

Parameters:

container - RMContainer.