我不确定我的Flink应用程序是否需要水印。什么时候需要水印?
如果我不需要它们,WatermarkStrategy.noWatermarks()
有什么用途?
我不确定我的Flink应用程序是否需要水印。什么时候需要水印?
如果我不需要它们,WatermarkStrategy.noWatermarks()
有什么用途?
KeyedProcessFunction
API使用,并且还被以下组件内部使用:
WatermarkStrategy
:env.fromSource(source, watermarkStrategy, sourceName);
WatermarkStrategy.noWatermarks()
。
WatermarkStrategy.noWatermarks()
,那么窗口是否会关闭并进行进度?或者如果我想避免使用水印,是否必须使用处理时间? - Asim Jalis