3.3.2.1 默认触发逻辑 3.3.2.1 默认触发逻辑:当窗口“以为自己该关了”,却忘了有人还在往里塞数据 “我们上线后第七天凌晨三点十七分,Flink作业的水位线(watermark)突然倒流——不是跳变,是缓慢、持续、不可逆地回退了 42 秒。下游聚合结果开始重复计数,监控告警像被踩了尾巴的猫一样炸开。运维同事在 Slack 里发了个 GIF:一只仓鼠在滚轮上疯狂蹬车,轮子却在倒转。” —— 某电商实时风控团队事故复盘纪要,2023.11.08 这不是玄学。这是 在默认配置下,与乱序事件、动态水位线、以及你那台默默吞掉 37% 延迟数据的 Kafka 消费者之间,一次猝不及防的正面碰撞。