flink sql 任务滑动窗口失效

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

flink sql 任务滑动窗口失效

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




--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re:flink sql 任务滑动窗口失效

hailongwang


方便发下完整的 SQL 不?

在 2020-12-07 16:31:42,"xushanshan" <[hidden email]> 写道:
>业务场景:
>滑动窗口大小5分钟,滑动频率1分钟,使用事件事件做watermark,发现滑动窗口的计算结果输出包含delete状态的数据且窗口计算的触发频率不是配置的1分钟,问题的原因是什么?
>
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: flink sql 任务滑动窗口失效

xushanshan
In reply to this post by xushanshan