好滴呀 谢谢各位老师指导
| | 小昌同学 | | ccc0606fight...@163.com | ---- 回复的原邮件 ---- | 发件人 | Yanfei Lei<fredia...@gmail.com> | | 发送日期 | 2023年8月10日 11:50 | | 收件人 | <user-zh@flink.apache.org> | | 主题 | Re: Flink 窗口触发条件 | hi, 感觉和[1]的问题比较像,事件时间的window在onElement和onEventTime时会触发,这两个方法又会根据watermark判断,可以看看o.a.f.table.runtime.operators.window.triggers包和o.a.f.table.runtime.operators.wmassigners包。 [1] https://juejin.cn/post/6850418110010179597 小昌同学 <ccc0606fight...@163.com> 于2023年8月10日周四 10:52写道: 各位老师好,我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下各位老师 我是开了一个2分钟的事件时间的窗口,但是等到两分钟后窗口并没有主动触发,等我后面再发一条数据的时候,窗口再进行了触发 所以我想请问一下窗口的触发机制不是时间点嘛,而是非要等到下一条数据发送,依赖于下一条数据携带的时间戳大于窗口的结束时间,上一个窗口才会真正的触发嘛 请各位老师指导一下 | | 小昌同学 | | ccc0606fight...@163.com | -- Best, Yanfei