如题,我目前计划自定义event time trigger实现分散触发。
比如0-5的窗口分散到6-11分触发, 从6开始是因为本身有个1min的乱序处理。
同时配合将allowedlateness设置为5min,这样避免窗口状态在触发之前被clean。

不知道想法是否OK呢?

回复