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 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 Description 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.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.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.
-