flinkの状態管理と復元方法は何ですか?
Flinkには、状態を管理および復元するための2つの方法、CheckpointとSavepointが提供されています。
- チェックポイント: チェックポイントは、Flinkがジョブの状態を永続化するためのメカニズムです。チェックポイントを実行すると、Flinkはジョブの状態を永続ストレージに保存し、障害が発生した場合にジョブの状態を復元できるようにします。チェックポイントの間隔時間や永続化方法を設定することで、異なる粒度の状態保護を実現できます。
- セーブポイントは、手動でトリガーされる状態のスナップショットメカニズムで、ジョブの状態を永続的なストレージに保存することができます。ジョブが実行中でも、停止した場合でもセーブポイントを作成することができます。セーブポイントを使用することで、より柔軟な状態管理とジョブのバージョン管理を実現できます。
CheckPoint は自動状態管理機構であり、SavePoint は手動トリガーの状態スナップショットメカニズムです。両方を組み合わせて使用することで、ジョブの状態を網羅的に管理して復元することができます。