org.apache.flink.runtime.resourcemanager.slotmanager

Interface ResourceAllocationStrategy

All Known Implementing Classes:

DefaultResourceAllocationStrategy

public interface ResourceAllocationStrategy

Strategy for allocating slots and task managers to fulfill the unfulfilled requirements.

Method Summary

Modifier and Type	Method and Description
ResourceAllocationResult	tryFulfillRequirements(Map<JobID,Collection<ResourceRequirement>> missingResources, org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerResourceInfoProvider taskManagerResourceInfoProvider, BlockedTaskManagerChecker blockedTaskManagerChecker) Try to make an allocation decision to fulfill the resource requirements.

Method Detail

tryFulfillRequirements

ResourceAllocationResult tryFulfillRequirements(Map<JobID,Collection<ResourceRequirement>> missingResources,
                                                org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerResourceInfoProvider taskManagerResourceInfoProvider,
                                                BlockedTaskManagerChecker blockedTaskManagerChecker)

Try to make an allocation decision to fulfill the resource requirements. The strategy generates a series of actions to take, based on the current status.

Notice: For performance considerations, modifications might be performed directly on the input arguments. If the arguments are reused elsewhere, please make a deep copy in advance.

Parameters:

missingResources - resource requirements that are not yet fulfilled, indexed by jobId

taskManagerResourceInfoProvider - provide the registered/pending resources of the current cluster

blockedTaskManagerChecker - blocked task manager checker

Returns:

a ResourceAllocationResult based on the current status, which contains whether the requirements can be fulfilled and the actions to take