You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/08/05 02:45:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Zhu Zhu closed FLINK-18690.
---------------------------
    Fix Version/s: 1.12.0
       Resolution: Fixed

Done via:
2542d86861cd5dd94feb9fcc92ef8e06398c8241
cfda0e0bb743ac2573d51476ece35d3441a8018f

> Implement LocalInputPreferredSlotSharingStrategy
> ------------------------------------------------
>
>                 Key: FLINK-18690
>                 URL: https://issues.apache.org/jira/browse/FLINK-18690
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Andrey Zagrebin
>            Assignee: Zhu Zhu
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.12.0
>
>         Attachments: case1.png
>
>
> 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)