Question

监控当前事件时间

Flink 的 活动时间 和水印支持是处理无序事件的强大函数。然而，由于在系统内跟踪时间的进展，因此很难理解究竟发生了什么。

可以通过 Flink Web 界面或 度量系统 访问每个任务的低水印。

Flink 中的每个任务都公开一个名为的度量 currentLowWatermark ，表示此任务接收的最低水印。该长值表示“当前事件时间”。该值是通过获取上游算子收到的所有水印的最小值来计算的。这意味着用水印跟踪的事件时间总是由最远的源控制。

可以 使用 Web 界面 ，通过在“度量标准”选项卡中选择任务并选择 <taskNr>.currentLowWatermark 度量标准来访问低水印度量标准。在新框中，您现在可以看到任务的当前低水印。

得到度量的另一方式是使用一个 度量报告 ，对于所述文档中所述 度量系统 。对于本地设置，我们建议使用 JMX 度量标准报告器和 VisualVM 之 类的工具。

处理事件时间 Stragglers

• 方法 1：水印停留较晚（表示完整性），窗口提前激活
• 方法 2：具有最大延迟的水印启发式，窗口接受迟到数据