Uses of Interface
org.apache.flink.runtime.blocklist.BlockedTaskManagerChecker

Packages that use BlockedTaskManagerChecker

Package	Description
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.resourcemanager.slotmanager

Uses of BlockedTaskManagerChecker in org.apache.flink.runtime.jobmaster.slotpool

Constructors in org.apache.flink.runtime.jobmaster.slotpool with parameters of type BlockedTaskManagerChecker

Constructor and Description
BlocklistDeclarativeSlotPoolFactory(BlockedTaskManagerChecker blockedTaskManagerChecker)

Uses of BlockedTaskManagerChecker in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type BlockedTaskManagerChecker

Modifier and Type	Method and Description
void	DeclarativeSlotManager.start(ResourceManagerId newResourceManagerId, Executor newMainThreadExecutor, ResourceAllocator newResourceAllocator, ResourceEventListener newResourceEventListener, BlockedTaskManagerChecker newBlockedTaskManagerChecker) Starts the slot manager with the given leader id and resource manager actions.
void	SlotManager.start(ResourceManagerId newResourceManagerId, Executor newMainThreadExecutor, ResourceAllocator newResourceAllocator, ResourceEventListener resourceEventListener, BlockedTaskManagerChecker newBlockedTaskManagerChecker) Starts the slot manager with the given leader id and resource manager actions.
void	FineGrainedSlotManager.start(ResourceManagerId newResourceManagerId, Executor newMainThreadExecutor, ResourceAllocator newResourceAllocator, ResourceEventListener newResourceEventListener, BlockedTaskManagerChecker newBlockedTaskManagerChecker) Starts the slot manager with the given leader id and resource manager actions.
ResourceAllocationResult	DefaultResourceAllocationStrategy.tryFulfillRequirements(Map<JobID,Collection<ResourceRequirement>> missingResources, org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerResourceInfoProvider taskManagerResourceInfoProvider, BlockedTaskManagerChecker blockedTaskManagerChecker)
ResourceAllocationResult	ResourceAllocationStrategy.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.