[
https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-14060:
-------------------------------------
Assignee: Zhu Zhu
> Set slot sharing groups according to pipelined regions
> ------------------------------------------------------
>
> Key: FLINK-14060
> URL: https://issues.apache.org/jira/browse/FLINK-14060
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Xintong Song
> Assignee: Zhu Zhu
> Priority: Major
>
> {{StreamingJobGraphGenerator}} set slot sharing group for operators at
> compiling time.
> -Identify pipelined regions, with respect to
> {{allSourcesInSamePipelinedRegion}}-
> -Set slot sharing groups according to pipelined regions -
> -By default, each pipelined region should go into a separate slot sharing
> group-
> -If the user sets operators in multiple pipelined regions into same slot
> sharing group, it should be respected-
> The slot sharing group of a vertex is determined as:
> * if a vertex slot sharing group is specified to be {{null}}, the slot
> sharing group is null
> * if a vertex slot sharing group is specified to be a non-default value(the
> group name not "default"), it will be respected
> * if a vertex slot sharing group is "default", it will be the slot sharing
> group of the vertex's logical pipelined region
> The slot sharing group of a region is determined as:
> * if {{allVerticesInSameSlotSharingGroupByDefault}} is true, all regions are
> in the same "default" slot sharing group
> * if {{allVerticesInSameSlotSharingGroupByDefault}} is false, all regions
> will be in distinct slot sharing groups
> This step should not introduce any behavior changes, given that later
> scheduled pipelined regions can reuse slots from previous scheduled pipelined
> regions.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
