public interface PhysicalSlotRequestBulkChecker
The check stops when all pending physical slot requests of
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
|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–2022 The Apache Software Foundation. All rights reserved.