[jira] [Assigned] (FLINK-17014) Implement PipelinedRegionSchedulingStrategy

["Zhu Zhu (Jira)" <ji...@apache.org>]

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

Zhu Zhu reassigned FLINK-17014:
-------------------------------

    Assignee: Zhu Zhu

> Implement PipelinedRegionSchedulingStrategy
> -------------------------------------------
>
>                 Key: FLINK-17014
>                 URL: https://issues.apache.org/jira/browse/FLINK-17014
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>    Affects Versions: 1.11.0
>            Reporter: Zhu Zhu
>            Assignee: Zhu Zhu
>            Priority: Major
>             Fix For: 1.11.0
>
>
> The PipelinedRegionSchedulingStrategy submits one pipelined region to the DefaultScheduler each time. The PipelinedRegionSchedulingStrategy must be aware of the inputs of each pipelined region. It should schedule a region if and only if all the inputs of that region become consumable.
> PipelinedRegionSchedulingStrategy can implement as below:
>  * startScheduling() : schedule all source regions one by one.
>  * onPartitionConsumable(partition) : Check all the consumer regions of the notified partition, if all the inputs of a region have turned to be consumable, schedule the region
>  * restartTasks(tasksToRestart) : find out all regions which contain the tasks to restart, reschedule those whose inputs are all consumable



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