<http://apache-flink.147419.n8.nabble.com/file/t1225/Snipaste_2020-12-30_10-55-48.png>
 
需求:每隔5分钟输出凌晨到当前的数据量

方案:使用滑动窗口,步长为5,通过where条件过滤出今天的数据进行count(1)

现象:00:05凌晨5分的时候窗口触发,发现累加值并不是今天的数据量,而是在当前窗口内的所有数据,不知道是不是bug,或者是我这边条件使用不正确,还麻烦社区帮忙解决下

理解:咨询了一下,好像这个where条件是在数据源端触发的,也就是数据进来的时候,符合条件的数据才流到窗口内,而不是在窗口内触发where条件过滤的,不知道有什么方法可以在窗口内触发filter不



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复