flinkがサポートしているかどうかを確認してください。

Question

私はちょうどApacheのflinkを学び始めて、フォールリングの問題を抱え始めています： どうすればflinkジョブを中断してから再開できますか？ コマンドラインを使用してジョブを一時停止するにはどうすればよいですか？

Answer 1

はい、あなたは確かにFlinkでこれを行うことができます。 savepointsについては、command lineまたはREST APIからトリガーすることができます。

更新

通常、ストリームプロセッサの目標は、彼らが利用可能になると新しい要素の連続、即時処理を行うことです。処理を中断したい場合は、しばらくソースを無視して到着するイベントを削除するか、時間のためにコンピューティングリソースを節約し、後で何も失うことなく再開するという願望を持っていると思います入力。

RichCoFlatmapおよびCoProcessFunctionは、役に立つと思われるビルディングブロックです。たとえば、ソケットに接続されたコントロールストリームをセットアップして、プライマリストリームを「サスペンド」する場合は、プライマリストリームの入力を停止させるイベントを送信するか、ブロッキング読み出しを行うか、スリープ状態にします、 例えば。

または、ジョブの上に独自の抽象レイヤーを追加し、そのジョブIDが変更されることに対処することも考えられます。ジョブは、セーブポイント/再起動の間に変更されない名前を持つことができます。