WatermarkGenerator接口有onEvent和onPeriodicEmit, onPeriodicEmit 会周期性调用,可能可以在这里实现一个多长时间没有调onEvent就发一个计算出来的新的watermark的逻辑,新的watermark比当前的watermark对应的窗口时间都更晚应该就能触发所有窗口了
On Mon, Nov 1, 2021 at 5:20 PM yuankuo.xia <[email protected]> wrote: > hi > > > 背景：我在使用eventTime窗口进行聚合计算，但是数据不连续，比如：A,B时间段之内都有数据流入，但A时间段和B时间段中间有30分钟无数据流入 > > > 问题：由于数据不连续，导致A时间段的最后一个窗口不会触发，一直等到新数据流入才能触发。 > > > 是否有方案解决以上问题，比如：一段时间无数据流入，则触发所有窗口。我看了trigger接口，但是没有想到好的实现方案。
