关于官方文件中闪烁水印插图的问题

Question

最近我阅读了关于水印的Flink官方文件。

网址：https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/event_time.html

有两幅图片说明了flink水印机制，这让我困惑不解：

Flink水印

第一张图片很容易理解，但是在第二张图片中，我想知道我们如何得到w（11）和w（17）？众所周知，我们可以在flink作业中定义如何生成水印，换句话说，水印是由一定的规则生成的。那么在第二张图片中生成水印的规则是什么？

我查找了几乎所有不同版本flink的官方文档，它们使用的图片都是相同的。这让我很困惑。有什么解释吗

Answer 1

你是对的；这个例子令人困惑。虽然它确实说明了一种可能的情况，但这并不容易理解。

通常，水印是使用有界无序水印策略生成的，其中时间戳赋值器跟踪迄今为止看到的最大时间戳（作为在流记录的元数据中分配时间戳的副作用）。然后，每次定期水印生成器的计时器关闭时（默认情况下，每200毫秒一次），指定的有界延迟将从最大时间戳中减去，并且结果将用于创建新水印（前提是生成的时间戳大于以前的水印）。

在该图所示的示例中，W（17）之前的最大时间戳似乎是22，因此有界延迟大概是5。根据同样的推理，因此应该在W（11）之前有一个时间16的事件，但如果有，它是在时间7的事件之前的某个地方。