我最近遇到了一个场景,就是当我使用window和periodic watermark的时候。
如果我的window时间设置的比较短,比如3秒,然后数据流假设为(6,5,3,1,2,4)。
此时watermark还没有产生,那么应该会有两个并行的window被创建(3,1,2)(6,5,4)。
这时watermark产生了,时间戳是7,同时超过了这两个窗口的边界.
那么此时会发生什么,两个窗口同时触发计算,或者第一窗口触发计算?*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。