Flink ジョブの実行に Yarn を使用しています。Flink ジョブごとにチェックポイントを作成しています。
Yarn クラスターで実行される Flink ジョブを送信します。Yarn でジョブが失敗したかどうかを確認して再起動するポーリング ジョブがあります。ジョブが再度送信されると、Yarn はこの Flink ジョブの新しい application_id を作成します。再送信された Flink ジョブが再起動された Flink ジョブのチェックポイントを使用するように構成するにはどうすればよいですか。
state.savepoints.dir = hdfs://localhost:9000/checkpoint/flink-conf.yaml` でconf を設定し
ました
Flink ジョブを作成するとき、
streamExecutionEnvironment.setStateBackend(new FsStateBackend("hdfs://localhost:9000/checkpoint/uuid-job-1"));
この設定を行うと、チェックポイントはhdfs://localhost:9000/checkpoint/、Flink ジョブの作成時に設定したパスではなく、conf ファイル ( ) で指定されたパスに保存されます。
どんな助けでも大歓迎です。ありがとう！