watermark

背景 我负责一条 B 端 SaaS 的实时指标看板链路：埋点/订单事件 → Kafka（16 分区）→ Flink 微批聚合（窗口 10s，watermark 允许 30s 迟到）→ ClickHouse → 业务看板。业务方的 SLA 是

实时看板比离线报表低 4.2%：迟到数据、回刷窗口与双写修正的完整链路 «结论先行：「实时看板 vs 离线报表对不上」绝大多数不是 bug，而是迟到数据 + 聚合不可回刷两个机制叠加的结果。解法不是把 Flink 调快，而是给指标明确定义「