Flink Source耗尽判定机制详解 Flink Source耗尽判定机制详解 一、核心原理 Flink通过监控SourceFunction.run()方法是否返回来判定Source是否耗尽。 SourceFunction接口契约 public interface SourceFunction<T> extends Function, 2025-12-30 flink 3 yoxih
Watermark与allowedLateness详解 Watermark与allowedLateness详解 概述 在Flink流处理中，处理乱序数据需要两层机制： Watermark：决定何时触发窗口计算 allowedLateness：决定窗口触发后是否继续接受迟到数据 一、两者的关系 它们是两层不同的乱序容忍机制： 1. Watermark（第一 2025-12-30 flink 3 yoxih
yoxih
