Andrey Zagrebin created FLINK-18739:
---------------------------------------
Summary: Implement MergingSharedSlotProfileRetriever
Key: FLINK-18739
URL: https://issues.apache.org/jira/browse/FLINK-18739
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Andrey Zagrebin
Assignee: Andrey Zagrebin
Input location preferences will be considered for each SharedSlot when
allocating a physical slot for it. Input location preferences of a SharedSlot
will be the merge of input location preferences of all the tasks to run in this
SharedSlot.
Inter-ExecutionSlotSharingGroup input location preferences can be respected in
this way for ExecutionSlotSharingGroups belonging to different bulks. If
ExecutionSlotSharingGroups belong to the same bulk, the input location
preferences are ignored because of possible cyclic dependencies. Later, we can
optimise this case when the declarative resource management for reactive mode
is ready.
Intra-ExecutionSlotSharingGroup input location preferences will also be
respected when creating ExecutionSlotSharingGroup(s) in
DefaultSlotSharingStrategy.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
