Flink水印如何准确判断事件迟到？

Question

我在读书https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/event_timestamp_extractors.html#fixed-迟到的次数，看起来是在说如果

当事件时间等于水印时怎么样？如果t_eventime=t_waterwark，那么这个事件不晚吗？

我以前一直认为如果t_eventime

请给我看看发生确定的代码，谢谢。




Answer 1

实际上，在这种情况下，确定事件是否延迟的代码似乎使用了<代码>

    protected boolean isElementLate(StreamRecord<IN> element) {
        return (windowAssigner.isEventTime())
                && (element.getTimestamp() + allowedLateness
                        <= internalTimerService.currentWatermark());
    }

现在，为了完整性起见，请注意，您所引用的策略的水印本身的值计算为所看到的最新时间戳，减去“无序度”，再减去1。

    public void onPeriodicEmit(WatermarkOutput output) {
        output.emitWatermark(new Watermark(maxTimestamp - outOfOrdernessMillis - 1));
    }

这意味着在上面的第一个片段中，用于比较的实际延迟时间比直觉告诉我们的延迟时间多1毫秒

现在这些参数是指我们认为我们的数据在现实世界中可能有多无序的估计，可能是由于网络竞争条件或不对齐的时钟等，并且我们在进行估计时通常比1 ms精确得多。所以这一切都不应该那么重要：希望这样的情况在我们的数据中很少见，尽管由于数据本身的原因，有多少通常有点随机。