3.3.1.3 会话窗口

文档摘要

3.3.1.3 会话窗口 3.3.1.3 会话窗口：当“用户没走远”遇上“数据不等人”——一个被低估的边界条件，如何用的毫米级调优撬动端到端延迟下降 47% 你有没有遇到过这样的场景？凌晨两点，监控告警突兀地刺穿静默——Flink 作业的指标在 5 分钟内陡增 300%，下游 Kafka 分区积压飙升，而上游日志里只有一行轻描淡写的。运维同事甩来截图：“窗口关得太晚了。” 数据同学追问：“为什么用户点击‘加入购物车’和‘提交订单’被分到两个窗口？” 业务方拍桌：“我们定义的‘一次会话’就是用户连续操作不超过 30 秒——你们的窗口得按这个逻辑切！” ——这不是配置错误。这是对会话窗口（Session Window）最本质矛盾的一次直面：它既不能太“粘”，把本该分离的行为强行缝合；