Flink streaming：如何控制执行时间

Question

Spark流提供终止awaitTermination（）的API。有没有类似的API可以在几秒钟后正常关闭flink流？

Answer 1

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

请注意，Flink流式数据流将无限期地继续执行，除非您使用的是有限数量元素的“有界”数据源。你也可以取消或停止一项工作，甚至在稍后停下来恢复检查点。