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

2021-11-03 文章 wang edmond
你好： 可以设置水位线的生成的空闲时间，超过空闲时间没有事件也会生成水位线。 可以参见官方文档中的 Dealing With Idle Sourcces部分 https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/event-time/generating_watermarks/ Generating Watermarks | Apache Flink

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

2021-11-03 文章 罗根(夕肆)
WatermarkGenerator接口有onEvent和onPeriodicEmit, onPeriodicEmit会周期性调用,可能可以在这里实现一个多长时间没有调onEvent就发一个计算出来的新的watermark的逻辑,新的watermark比当前的watermark对应的窗口时间都更晚应该就能触发所有窗口了 -- 发件人：yuankuo.xia 发送时间：2021年11月1日(星期一) 17:20 收件人：user-zh 主　题：关于窗口计算，