org.apache.flink.runtime.jobmaster.slotpool

Class PhysicalSlotProviderImpl

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlotProviderImpl

All Implemented Interfaces:

PhysicalSlotProvider

public class PhysicalSlotProviderImpl
extends Object
implements PhysicalSlotProvider

The provider serves physical slot requests.

Constructor Summary

Constructors

Constructor and Description
PhysicalSlotProviderImpl(SlotSelectionStrategy slotSelectionStrategy, SlotPool slotPool)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<PhysicalSlotRequest.Result>	allocatePhysicalSlot(PhysicalSlotRequest physicalSlotRequest) Submit a request to allocate a physical slot.
void	cancelSlotRequest(SlotRequestId slotRequestId, Throwable cause) Cancels the slot request with the given SlotRequestId.
void	disableBatchSlotRequestTimeoutCheck() Disables batch slot request timeout check.

Methods inherited from class java.lang.Object

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

Constructor Detail

PhysicalSlotProviderImpl

public PhysicalSlotProviderImpl(SlotSelectionStrategy slotSelectionStrategy,
                                SlotPool slotPool)

Method Detail

disableBatchSlotRequestTimeoutCheck

public void disableBatchSlotRequestTimeoutCheck()

Description copied from interface: PhysicalSlotProvider

Disables batch slot request timeout check. Invoked when someone else wants to take over the timeout check responsibility.

Specified by:

disableBatchSlotRequestTimeoutCheck in interface PhysicalSlotProvider

allocatePhysicalSlot

public CompletableFuture<PhysicalSlotRequest.Result> allocatePhysicalSlot(PhysicalSlotRequest physicalSlotRequest)

Description copied from interface: PhysicalSlotProvider

Submit a request to allocate a physical slot.

The physical slot can be either allocated from the slots, which are already available for the job, or a new one can be requeted from the resource manager.

Specified by:

allocatePhysicalSlot in interface PhysicalSlotProvider

Parameters:

physicalSlotRequest - slot requirements

Returns:

a future of the allocated slot

cancelSlotRequest

public void cancelSlotRequest(SlotRequestId slotRequestId,
                              Throwable cause)

Description copied from interface: PhysicalSlotProvider

Cancels the slot request with the given SlotRequestId.

If the request is already fulfilled with a physical slot, the slot will be released.

Specified by:

cancelSlotRequest in interface PhysicalSlotProvider

Parameters:

slotRequestId - identifying the slot request to cancel

cause - of the cancellation