95-262-040-源碼-Flink重新開機政策-簡介 Task恢複政策

文章目錄

• • 2. 概述
  • 3.固定間隔
  • 4.失敗率
  • • 4.1 案例
  • 5. 無重新開機政策
  • • 5.1 案例
  • 6.實際代碼示範
• 7. Task恢複政策
• M.參考

2. 概述

​ Flink支援不同的重新開機政策，這些重新開機政策控制着job失敗後如何重新開機。叢集可以通過預設的重新開機政策來重新開機，這個預設的重新開機政策通常在未指定重新開機政策的情況下使用，而如果Job送出的時候指定了重新開機政策，這個重新開機政策就會覆寫掉叢集的預設重新開機政策。

• Flink支援不同的重新開機政策，以在故障發生時控制作業如何重新開機
• 叢集在啟動時會伴随一個預設的重新開機政策，在沒有定義具體重新開機政策時會使用該