Flink streaming:如何控制执行时间

Question

Spark streaming提供了销毁awaitTermination()的接口。有没有类似的API可以在t秒后优雅地关闭flink流？

Answer 1

当流式作业执行时，Flink中的驱动程序(即main方法)不会保持运行。您的程序应该定义一个数据流，调用execute，然后终止。在Spark中，驱动程序保持运行(AFAIK)，而awaitTermination与此相关。

请注意，Flink流数据流将继续无限期地执行，除非您使用的是具有有限数量元素的“有界”数据源。您还可以取消或停止作业，甚至可以在停止时获取检查点，以便稍后恢复。