org.apache.flink.runtime.jobmaster.slotpool

Interface PhysicalSlotRequestBulkChecker

All Known Implementing Classes:

PhysicalSlotRequestBulkCheckerImpl

public interface PhysicalSlotRequestBulkChecker

This class tracks a fulfillability timeout of a bulk of physical slot requests.

The check stops when all pending physical slot requests of PhysicalSlotRequestBulk are fulfilled by available or newly allocated slots. The bulk is fulfillable if all its physical slot requests can be fulfilled either by available or newly allocated slots or slots which currently used by other job subtasks. The bulk gets canceled if the timeout occurs and the bulk is not fulfillable. The timeout timer is not running while the bulk is fulfillable but not fulfilled yet.

Method Summary

Modifier and Type	Method and Description
void	schedulePendingRequestBulkTimeoutCheck(PhysicalSlotRequestBulk bulk, Time timeout) Starts tracking the fulfillability of a PhysicalSlotRequestBulk with timeout.
void	start(ComponentMainThreadExecutor mainThreadExecutor) Starts the bulk checker by initializing the main thread executor.

Method Detail

start

void start(ComponentMainThreadExecutor mainThreadExecutor)

Starts the bulk checker by initializing the main thread executor.

Parameters:

mainThreadExecutor - the main thread executor of the job master

schedulePendingRequestBulkTimeoutCheck

void schedulePendingRequestBulkTimeoutCheck(PhysicalSlotRequestBulk bulk,
                                            Time timeout)

Starts tracking the fulfillability of a PhysicalSlotRequestBulk with timeout.

Parameters:

bulk - PhysicalSlotRequestBulk to track

timeout - timeout after which the bulk should be canceled if it is still not fulfillable.