[
https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-14060:
-----------------------------------
Component/s: Runtime / Coordination
> 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
> 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
> 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)
