好滴呀 谢谢各位老师指导



| |
小昌同学
|
|
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

回复