Spark 流提供了用于终止 awaitTermination(( 的 API。 是否有任何类似的 API 可用于在 t 秒后优雅地关闭 flink 流？
在流式处理作业执行时，Flink 中的驱动程序(即main方法(不会保持运行状态。 程序应定义数据流，调用execute，然后终止。 在 Spark 中，驱动程序保持运行 (AFAIK(，awaitTermination与此相关。
请注意，Flink 流数据流会无限期地继续执行，除非您使用的是具有有限数量元素的"有界"数据源。 您也可以取消或停止作业，甚至可以在停止时采取检查点，以便稍后恢复。