Apache Flink CEP Timout Pattern in not define by time window

Question

我使用PatternTimeoutFunction在事件序列超出定义的时间窗口时丢弃它。

我正在设置水印如下

public Watermark checkAndGetNextWatermark(Event lastElement, long extractedTimestamp) {
    return new Watermark(extractedTimestamp);
}

当模式超时发生时，< code>timeoutTimestamp应等于timewindow的第一个事件时间戳值

但是超时是在接收到下一个水印后触发的。是否在收到下一个水印后触发超时，或基于< code>timeWindow到期？

Answer 1

如果使用事件时间，则超时由水印的接收触发。因为只有收到此时间戳的水印，才能确保在某一点之前看到所有元素。

这意味着超时时间戳可以大于第一个事件时间戳窗口长度，这取决于下一个水印的值。因此，超时时间戳实际上是您意识到模式超时的事件时间。