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

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

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

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