apache-flink - Apache Flink CEP 超时模式未由时间窗口定义

Question

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

我将水印设置如下

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

当模式超时发生时，timeoutTimestamp应该等于第一个事件时间戳 + 时间窗口的值

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

Answer 1

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

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