public interface PhysicalSlotRequestBulkChecker
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.
|Modifier and Type||Method and Description|
Starts tracking the fulfillability of a
Starts the bulk checker by initializing the main thread executor.
void start(ComponentMainThreadExecutor mainThreadExecutor)
mainThreadExecutor- the main thread executor of the job master
void schedulePendingRequestBulkTimeoutCheck(PhysicalSlotRequestBulk bulk, Time timeout)
timeout- timeout after which the bulk should be canceled if it is still not fulfillable.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.