Hi, 我猜是因为设的1小时滚动窗口，WindowFunction里拿到的WindowEnd就是1小时的END， 而acc其实没有变化，也就是每隔20s触发拿到的结果是一样的，在MapState里也会忽略重复值。
你可以让acc做个累加，然后结果输出里把acc的值带上看看。 Best, shizk233 罗显宴 <15927482...@163.com> 于2020年7月20日周一 下午8:44写道： > > 大佬，不好意思，可能图片看不到，我把代码发一次，刚学习flink半个月，好多不懂，希望大佬莫嫌烦 > 罗显宴 > 邮箱：15927482...@163.com > > <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E7%BD%97%E6%98%BE%E5%AE%B4&uid=15927482803%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fwzpmmc%2Fba95f912526bde9c6f0f1ae6f5b9b114.jpg&items=%5B%22%E9%82%AE%E7%AE%B1%EF%BC%9A15927482803%40163.com%22%5D> > 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 > 在2020年7月20日 20:38，罗显宴<15927482...@163.com> <15927482...@163.com> 写道： > > 不好意思，刚才发的快，没来得及解释， > 这里aggregate算子主要做了一个预聚合，把窗口的个数置为一，然后用windowResult输出结果，然后对窗口分区，最后用mapState处理递增 > > > 罗显宴 > 邮箱：15927482...@163.com > > <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E7%BD%97%E6%98%BE%E5%AE%B4&uid=15927482803%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fwzpmmc%2Fba95f912526bde9c6f0f1ae6f5b9b114.jpg&items=%5B%22%E9%82%AE%E7%AE%B1%EF%BC%9A15927482803%40163.com%22%5D> > 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 > 在2020年7月20日 14:09，罗显宴<15927482...@163.com> <15927482...@163.com> 写道： > > > > 不是，是连续累计，比如我在某个医药网站上爬取有关药物，每小时统计爬取到的新增药物种类，然后一直这样进行下去，然后这个网站爬完了，可以换另一个网站， > | | > 罗显宴 > | > | > 邮箱：15927482...@163.com > | > 签名由网易邮箱大师定制 > 在2020年7月20日 11:47，shizk233<wangwangdaxian...@gmail.com> 写道： > Hi, > > 累计是仅在一天之内累计吗，这样的话可以开个一天的Tumbling > Window，然后使用ContinusEventTimeTrigger每小时触发一下输出结果。 > > Best, > shizk233 > > 罗显宴 <15927482...@163.com> 于2020年7月20日周一 上午1:18写道： > > > > 大家好，怎么实现一个滚动窗口内的连续递增元素个数，比如每小时累计用户登录数，比如说凌晨1点登录了500人，到了两点就累计到1200，到3点累计到，，，，这样实现一个递增曲线，在网上看到云邪大佬写的sql但是不会写datastream > api，希望看到的大佬能帮我解惑一下，谢谢啦 > > | | > 罗显宴 > | > | > 邮箱：15927482...@163.com > | > > 签名由 网易邮箱大师 定制 > >
