Chesnay Schepler created FLINK-20748:
----------------------------------------
Summary: Remap excess slots to outstanding requirements
Key: FLINK-20748
URL:
https://issues.apache.org/jira/browse/FLINK-20748 Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Affects Versions: 1.13.0
Reporter: Chesnay Schepler
Fix For: 1.13.0
The {{DeclarativeSlotPool}} maintains a mapping of slots to requirements that they fulfill. This mapping is currently determined when the slot is offered to the pool, and is only modified if the scheduler reserves this slot for a different requirement.
This currently implies 2 things:
* a slot can be prematurely released, although it could fulfill a different outstanding requirement
* a new slot could be requested, despite there being another slot around that could fulfill the requirement
We should remedy this by checking whether excess slots can be re-mapped to a different requirement, whenever the requirements change or a slot is freed.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)