azagrebin opened a new pull request #13028:
URL: https://github.com/apache/flink/pull/13028
## What is the purpose of the change
Input location preferences will be considered for each `SharedSlot` when
allocating a physical slot for it. Input location preferences of a `SharedSlot`
are the merged input location preferences of all the tasks to run in this
`SharedSlot`.
Inter-`ExecutionSlotSharingGroup` input location preferences can be
respected in this way for `ExecutionSlotSharingGroup`s belonging to different
bulks. If `ExecutionSlotSharingGroup`s 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
`LocalInputPreferredSlotSharingStrategy `.
The PR is based on #13018 and #13009.
## Brief change log
- Introduce interfaces for `SharedSlotProfileRetriever` and
`SharedSlotProfileRetrieverFactory`
- Implement them with `MergingSharedSlotProfileRetriever` and
`MergingSharedSlotProfileRetrieverFactory`
- add unit tests
## Verifying this change
Unit tests.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
