Flinkストリーミング：実行時間を制御する方法

Question

スパークストリーミングは、awaitTermination（）の終了用のAPIを提供します。いくつかのt秒後にflinkストリーミングを正常にシャットダウンするために使用できる類似のAPIはありますか？

Answer 1

Flinkのドライバプログラム（mainメソッド）は、ストリーミングジョブの実行中は実行されません。プログラムでデータフローを定義し、executeを呼び出して終了してください。 Sparkでは、ドライバプログラムは実行中（AFAIK）のままであり、awaitTerminationはそれに関連しています。

Flinkストリーミングデータフローは、有限数の要素を持つ「限定」データソースを使用していない限り、無期限に実行されます。また、ジョブをキャンセルしたり停止したり、後で再開を中止するとチェックポイントを取ることさえできます。