操作符实例的事件时间是否可能变得更短？

Question

从下面URL中的“并行流中的水印”一节中，我们知道“操作员的当前事件时间是其输入流事件时间的最小值”https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/event_time.html

现在我们以window（1）实例的事件时间为例，我们知道事件时间是14(min(29,14))，但是如果发生以下序列的水印事件会发生什么呢？

如果水印事件29在水印事件14之前到达窗口（1）会发生什么？

例如，假设水印事件29首先到达窗口（1）实例，由于水印事件14还没有到达，所以首先将窗口（1）实例的事件时间设置为29，然后假设水印事件14也到达窗口（1）实例，则将窗口（1）实例的事件时间设置为14？（如果是这样，则窗口（1）的事件时间将从29变为14，变小），也假设源（2）生成水印39后，到达窗口（1）实例，则窗口（1）实例的事件时间将设置为29或39？

Answer 1

最后，我也从源代码处得到了答案，正如David所说的“窗口的水印将保持在long.min_value直到两个输入流都有一个更大的值。”

https://github.com/apache/flink/blob/57b950796deebed46ae95f97152e09b2e2655de8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator/abstractstreamoperator.java

public void processWatermark1(Watermark mark) throws Exception {
input1Watermark = mark.getTimestamp();
long newMin = Math.min(input1Watermark, input2Watermark);
if (newMin > combinedWatermark) {
  combinedWatermark = newMin;
  processWatermark(new Watermark(combinedWatermark));
}
}

public void processWatermark2(Watermark mark) throws Exception {
input2Watermark = mark.getTimestamp();
long newMin = Math.min(input1Watermark, input2Watermark);
if (newMin > combinedWatermark) {
  combinedWatermark = newMin;
  processWatermark(new Watermark(combinedWatermark));
}
}