Ch06-Flink 之 容错机制

December 13, 2020

Flink 容错机制

1. 作业容错 #

1.1 Task Failover 策略 #

• RestartAll
• RestartIndividualStrategy
• RestartPipelinedRegionStrategy

1.2 Job Restart 策略 #

• FixedDelayRestartStrategy
• FailureRateRestartStrategy
• NoRestartStrategy

2. 守护进程容错 #

2.1 JobManager 容错 #

2.1.1 ResourceManager 容错 #

2.1.2 JobMaster 容错 #

2.2 TaskManager 容错 #

2.3 并发故障 #

2.4 参考文献 #

• 深入理解 Flink 容错机制