回复：关于窗口计算，数据不连续，导致窗口延迟触发的问题。

Wed, 03 Nov 2021 01:02:03 -0700 

WatermarkGenerator接口有onEvent和onPeriodicEmit, 
onPeriodicEmit会周期性调用,可能可以在这里实现一个多长时间没有调onEvent就发一个计算出来的新的watermark的逻辑,新的watermark比当前的watermark对应的窗口时间都更晚应该就能触发所有窗口了


------------------------------------------------------------------
发件人：yuankuo.xia <[email protected]>
发送时间：2021年11月1日(星期一) 17:20
收件人：user-zh <[email protected]>
主　题：关于窗口计算，数据不连续，导致窗口延迟触发的问题。

hi


背景：我在使用eventTime窗口进行聚合计算，但是数据不连续，比如：A,B时间段之内都有数据流入，但A时间段和B时间段中间有30分钟无数据流入


问题：由于数据不连续，导致A时间段的最后一个窗口不会触发，一直等到新数据流入才能触发。


是否有方案解决以上问题，比如：一段时间无数据流入，则触发所有窗口。我看了trigger接口，但是没有想到好的实现方案。

回复