Everything about watermarks in Apache Flink
developer.confluent.io原文 ↗
Confluent 系统梳理 Flink 水位线的生成、传播和事件时间语义，说明乱序输入下窗口何时可以关闭。并行分区通常以全局最小水位线推进，迟到事件策略再决定结果是否更新；具体延迟阈值仍需结合业务 SLA 设定。
–浏览
developer.confluent.io原文 ↗
评论 · Comments