3.3.1.1 滚动窗口 3.3.1.1 滚动窗口:当“滑动”不再平滑——一个被低估的水位线偏移故障与它的根因解剖 你有没有在Flink作业上线后第三天凌晨两点被电话叫醒,被告知“实时UV突然归零,但PV还在涨”? 有没有在Kafka消费延迟跳涨到2小时时,发现所有滚动窗口的聚合结果像被剪掉尾巴的蛇——前半截数据全在,后半截凭空蒸发? 有没有对着Prometheus里那条锯齿状的 曲线发呆,一边刷新一边想:这到底是数据断了,还是窗口“漏”了? 别急着重启作业。 也先别翻Flink官网文档里那句轻描淡写的定义:“滚动窗口将流划分为固定大小、不重叠的连续窗口。” 这句话本身没错——但它像说“刀能切菜”,却没告诉你:刀刃卷了、砧板湿滑、手抖了三毫米,菜就飞出去了。 我们今天不讲概念。