[jira] [Created] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

Shang Yuanchun (Jira)
Andrey Zagrebin created FLINK-18690:
---------------------------------------

             Summary: Implement LocalInputPreferredSlotSharingStrategy
                 Key: FLINK-18690
                 URL: https://issues.apache.org/jira/browse/FLINK-18690
             Project: Flink
          Issue Type: Sub-task
            Reporter: Andrey Zagrebin
            Assignee: Zhu Zhu


Implement ExecutionSlotSharingGroup, SlotSharingStrategy and default LocalInputPreferredSlotSharingStrategy.

The default strategy would be LocalInputPreferredSlotSharingStrategy. It will try to reduce remote data exchanges. Subtasks, which are connected and belong to the same SlotSharingGroup, tend to be put in the same ExecutionSlotSharingGroup.

See [design doc|https://docs.google.com/document/d/10CbCVDBJWafaFOovIXrR8nAr2BnZ_RAGFtUeTHiJplw/edit#heading=h.t4vfmm4atqoy]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)