org.apache.flink.runtime.taskexecutor.slot

Interface SlotActions

public interface SlotActions

Interface to trigger slot actions from within the TaskSlotTable.

Method Summary

Modifier and Type	Method and Description
void	freeSlot(AllocationID allocationId) Free the task slot with the given allocation id.
void	timeoutSlot(AllocationID allocationId, UUID ticket) Timeout the task slot for the given allocation id.

Method Detail

freeSlot

void freeSlot(AllocationID allocationId)

Free the task slot with the given allocation id.

Parameters:

allocationId - to identify the slot to be freed

timeoutSlot

void timeoutSlot(AllocationID allocationId,
                 UUID ticket)

Timeout the task slot for the given allocation id. The timeout is identified by the given ticket to filter invalid timeouts out.

Parameters:

allocationId - identifying the task slot to be timed out

ticket - allowing to filter invalid timeouts out