业务场景: 滑动窗口大小5分钟,滑动频率1分钟,使用事件事件做watermark,发现滑动窗口的计算结果输出包含delete状态的数据且窗口计算的触发频率不是配置的1分钟,问题的原因是什么?
-- Sent from: http://apache-flink.147419.n8.nabble.com/
业务场景: 滑动窗口大小5分钟,滑动频率1分钟,使用事件事件做watermark,发现滑动窗口的计算结果输出包含delete状态的数据且窗口计算的触发频率不是配置的1分钟,问题的原因是什么?
-- Sent from: http://apache-flink.147419.n8.nabble.com/