從Flink架構(gòu)中我們可以看到，JobManager這個組件非常重要，是中心協(xié)調(diào)器，負(fù)責(zé)任務(wù)調(diào)度和資源管理。默認(rèn)情況下，每個Flink集群只有一個JobManager實例。這會產(chǎn)生單點故障（SPOF）：如果JobManager崩潰，則無法提交新程序，正在運行的程序也會失敗。通過JobManager的高可用性，用戶可以從JobManager故障中恢復(fù)，從而消除SPOF。

JobManager高可用性的一般思想是，任何時候都有一個leader JobManager和多個standby JobManage，當(dāng)leader出現(xiàn)故障時，其中一個standby JobManager接管leader。這保證了沒有單點故障，并且只要standby JobManager接管了leader，程序就可以繼續(xù)進(jìn)行。如下圖（有3個JobManager）：

Flink的高可用性服務(wù)封裝了使一切正常工作所需的服務(wù)：

• Leader election：從n個候選人中選出一個領(lǐng)導(dǎo)
• Service discovery：檢索當(dāng)前領(lǐng)導(dǎo)的地址
• State persistence