You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/07/23 13:18:00 UTC

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

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)