org.apache.flink.runtime.jobmaster.slotpool

Class ThrowingSlotProvider

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.ThrowingSlotProvider

All Implemented Interfaces:

SlotProvider

public class ThrowingSlotProvider
extends Object
implements SlotProvider

A slot provider that validates that it is not in use by throwing IllegalStateException on any method call.

Constructor Summary

Constructors

Constructor and Description
ThrowingSlotProvider()

Method Summary

Modifier and Type	Method and Description
CompletableFuture<LogicalSlot>	allocateSlot(SlotRequestId slotRequestId, ScheduledUnit scheduledUnit, SlotProfile slotProfile, Time allocationTimeout) Allocating slot with specific requirement.
void	cancelSlotRequest(SlotRequestId slotRequestId, SlotSharingGroupId slotSharingGroupId, Throwable cause) Cancels the slot request with the given SlotRequestId and SlotSharingGroupId.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.jobmaster.slotpool.SlotProvider

allocateBatchSlot, allocateSlot

Constructor Detail

ThrowingSlotProvider

public ThrowingSlotProvider()

Method Detail

allocateSlot

public CompletableFuture<LogicalSlot> allocateSlot(SlotRequestId slotRequestId,
                                                   ScheduledUnit scheduledUnit,
                                                   SlotProfile slotProfile,
                                                   Time allocationTimeout)

Description copied from interface: SlotProvider

Allocating slot with specific requirement.

Specified by:

allocateSlot in interface SlotProvider

Parameters:

slotRequestId - identifying the slot request

scheduledUnit - The task to allocate the slot for

slotProfile - profile of the requested slot

allocationTimeout - after which the allocation fails with a timeout exception

Returns:

The future of the allocation

cancelSlotRequest

public void cancelSlotRequest(SlotRequestId slotRequestId,
                              @Nullable
                              SlotSharingGroupId slotSharingGroupId,
                              Throwable cause)

Description copied from interface: SlotProvider

Cancels the slot request with the given SlotRequestId and SlotSharingGroupId.

Specified by:

cancelSlotRequest in interface SlotProvider

Parameters:

slotRequestId - identifying the slot request to cancel

slotSharingGroupId - identifying the slot request to cancel

cause - of the cancellation