[
https://issues.apache.org/jira/browse/FLINK-18957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin closed FLINK-18957.
-----------------------------------
Resolution: Done
merged into master by 2b4c8534b52f30390d1b2c0a0437c941d3690e90
> 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
> Priority: Major
> Labels: pull-request-available
> 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)
