闪烁计时器时间戳



如果Flink中的计时器在过去被设置为时间戳,它们会被触发吗?由于当前时间戳大于计时器服务的时间戳,它会立即被触发还是永远不会被触发?

此外,我们正试图根据事件时间对输入事件进行排序,方法是在基于处理时间的翻滚窗口中收集/缓冲输入事件,这样我们就不必丢弃延迟事件。有没有更好的解决方案来解决这个问题?

设置为过去时间戳的计时器将尽快触发。

有关排序,请参阅如何使用Flink对无序的事件时间流进行排序,以及如何使用FlinkSQL按事件时间对流进行排序。

相关内容

  • 没有找到相关文章

最新更新