现在有个需求是:收到客户的数据,进行处理后,每30S发送一条数据给客户,我这边是设置了一个flink会话窗口,设置30s的时间间隔,到那时出现了一个问题是,当下一条数据迟迟不过来的时候,窗口就失效了,不再消费数据进行处理
这不应该使用会话窗口吧 你直接设置一个滚动窗口 30s一滚动不就可以了 有数据就有数据没数据就空窗口跳过了呀 ,为什么要设置会话