采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
请问一下,如果数据源在某段时间没有数据,不推进水位线了,怎么让窗口在等待一段时间后触发计算?
水位线是根据当前窗口内最大的一条时间的记录往后变化的,如果没数据进来,那水位线还是在原来的那条最大的数据上的。
没有办法触发窗口计算了吗?
没有数据,触发也没啥意义了吧。这个是否触发。你可以造一波数据动手测试下看看
我意思是假设9:00-9:30这个窗口进来了一些数据,然后9:25就没数据进来了,水位线一直不推进,窗口里面是有数据的,但是窗口一直不触发的问题。可能我需要的是一个根据eventtime和等待时长去fire的trigger。我大概找到思路了。
登录后可查看更多问答,登录/注册
入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink
988 18
1.1k 15
1.5k 14
1.4k 13
1.6k 13