flink窗口触发问题

来源:16-8 重启策略测试

kingdomad

2020-10-17

请问一下,如果数据源在某段时间没有数据,不推进水位线了,怎么让窗口在等待一段时间后触发计算?

写回答

1回答

Michael_PK

2020-10-17

水位线是根据当前窗口内最大的一条时间的记录往后变化的,如果没数据进来,那水位线还是在原来的那条最大的数据上的。

0
4
Michael_PK
回复
kingdomad
不是的呢,你窗口到了,水位线在哪就是在哪,水位线用于延迟数据控制的场景呢
2020-10-18
共4条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程