[FLINK-5867] The implementation of RestartPipelinedRegionStrategy

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Component/s: Runtime / Coordination
• Assignee: shuai.xu
• Reporter: shuai.xu
• Created: 21/Feb/17 10:50
• Updated: 28/Feb/19 14:01
• Resolved: 07/Jul/17 09:21

Description

The RestartPipelinedRegionStrategy's responsibility is the following:
1. Calculate all FailoverRegions and their relations when initializing.
2. Listen for the failure of the job and executions, and find corresponding FailoverRegions to do the failover.

Issue Links

• links to: GitHub Pull Request #3773