Andrey Zagrebin created FLINK-18957:
---------------------------------------
Summary: Implement bulk fulfil-ability timeout tracking for shared
slots
Key: FLINK-18957
URL: https://issues.apache.org/jira/browse/FLINK-18957
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Andrey Zagrebin
Assignee: Andrey Zagrebin
Fix For: 1.12.0
Track fulfil-ability of required physical slots for all SharedSlot(s) (no
matter whether they are created at this bulk or not) with timeout. This ensures
we will not wait indefinitely if the required slots for this bulk cannot be
fully fulfilled at the same time.
# Create a LogicalSlotRequestBulk to track all physical requests and logical
slot requests (logical slot requests only which belong to the bulk)
# Mark physical slot request fulfilled in LogicalSlotRequestBulk, once its
future is done
# If any physical slot request fails then clear the LogicalSlotRequestBulk to
stop the fulfil-ability check
# Schedule a fulfil-ability check in LogicalSlotRequestBulkChecker for the
LogicalSlotRequestBulk
# In case of timeout:
# cancel/fail the logical slot futures of the bulk in SharedSlot(s)
# remove
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
