Flink streaming：如何控制執行時間

Question

Spark流提供終止awaitTermination（）的API。有沒有類似的API可以在幾秒鐘後正常關閉flink流？

Answer 1

Flink中的驅動程序（即main方法）在執行流式作業時不會保持運行狀態。你的程序應該定義一個數據流，調用execute，然後終止。在Spark中，驅動程序保持運行（AFAIK），awaitTermination與此相關。

請注意，Flink流式數據流將無限期地繼續執行，除非您使用的是有限數量元素的「有界」數據源。你也可以取消或停止一項工作，甚至在稍後停下來恢復檢查點。