キー値の状態とチェックポイントを一緒に使う方法は？

Question

私はキー値ステートインターフェースが自分のフローで失敗した後に状態を復元できることを理解していますが、フローの再デプロイ後に状態を復元することはできません。私はCheckpointedインタフェースを実装し、保存/ Checkpointedインターフェースのキーと値の状態での使用方法へ/から状態を復元する必要があり、再デプロイ後の状態を復元したい場合は

（+前に展開して、新しい実行セーブポイントを作成することを忘れないでください作成されたセーブポイントによるフロー）。右？

Answer 1

ローカルユーザインスタンス状態のCheckpointedインターフェイスまたはRuntimeContext経由のキーごとステータスを使用して、状態がチェックポイントされ、正しく復元されます。実際には、チェックポイントコードを実装する必要がないため、キーごとの状態を使用する方が簡単です。

Flinkジョブを明示的に停止し、チェックポイント状態が復元された後で再開する場合は、Savepointsを使用します。セーブポイントは、連続チェックポイントと同じメカニズムを使用します。これにより、障害発生時にジョブを再開できます。