<
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/
Locked
