spark streaming为termination（）提供api。有没有类似的api可以在几秒钟后优雅地关闭flink流媒体？
6mw9ycah1#
你的驱动程序（即 main 方法）在流式处理作业执行时，flink不会保持运行。你的程序应该定义一个数据流，调用 execute ，然后终止。在spark中，驱动程序保持运行（afaik），并且 awaitTermination 与此相关。请注意，flink流数据流继续无限期地执行，除非您使用的是具有有限元素数的“有界”数据源。您还可以取消或停止作业，甚至在停止时设置检查点，以便稍后继续。
main
execute
awaitTermination
1条答案
按热度按时间6mw9ycah1#
你的驱动程序（即
main方法）在流式处理作业执行时，flink不会保持运行。你的程序应该定义一个数据流，调用execute，然后终止。在spark中，驱动程序保持运行（afaik），并且awaitTermination与此相关。请注意，flink流数据流继续无限期地执行，除非您使用的是具有有限元素数的“有界”数据源。您还可以取消或停止作业，甚至在停止时设置检查点，以便稍后继续。