[
https://issues.apache.org/jira/browse/FLINK-17014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17014.
---------------------------
Resolution: Fixed
Implemented via
67835fe8b72601dbb046683c04cc9a4cedf77db3
99cbaa929ff9f2f5c387cbf4f76a0166f83a3a8c
> 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
> Labels: pull-request-available
> Fix For: 1.11.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)
