当源输入已耗尽时，Flink触发进程功能上的注册计时器

Question

我正在使用Flink流从包括文件在内的多个资源读取输入。我的目标是定期触发一些计算（流转时长），并在到达文件末尾时触发最终结果。我的处理子拓扑如下所示

myGenerator
   .generateData()
   .map(...)
   .keyBy(...)
   .process(new TriggerFunction(timeout));

我的生成器源之一可以是包含有界数据的文件

<代码>例如环境。readFile（inputFormat、filename、FileProcessingMode.PROCESS\u ONCE、interval、typeInfo）

因此，我想知道是否有一种机制可以捕获源操作符发送的事件，该事件表示已到达输入的末尾，并且预计不会有更多的事件发出拓扑拆卸的信号。

据我所知，当我的源到达输入端（文件）时，它标志着下游操作符的处理结束，因此我没有机会或方法触发通过udf处理函数中注册的定期计时器发出的最终结果。

我已尝试使用“FileProcessingMode”打开文件源。PROCESS\u CONTINUOUSLY“但这似乎更像是一种黑客行为，而不是一种解决方案。我还尝试使用带标点的水印使用水印策略，但我不确定如何从源中捕获\u输入的结尾并转发适当的水印（例如Long.MAX\u值）。

是否有办法确保即使源事件已耗尽，也能触发计时器？

Answer 1

对于有界源，Flink将自动发送一个带有值的水印。消耗所有输入后的MAX\U水印。因此，为Long创建一个事件时间计时器就足够了。最大值。