Flinkの耐障害性機構は障害時にプログラムを回復しそれらの実行を続けます。マシーンのハードウェア障害、ネットワーク障害、一時的なプログラムの障害などを含むそのような障害。 バッチ処理の耐障害性 (データセット API) 再試行の遅延 バッチ処理の耐障害性 (データセット API) データセット API内のプログラムのための耐障害性は、実行の失敗の再試行によって動作します。ジョブが失敗したと宣言される前にFlinkが実行を再試行する回数は、execution retries パラメータによって設定可能です。値0は事実上耐障害性が無効にされていることを意味します。 耐障害性を有効にするには、execution retries を0より大きな値に設定します。一般的な選択は3つの値です。 この例はFlinkデータセットプログラムのための実行の再試行を設定する方法を示します。 ExecutionE