如果Flink中的计时器在过去被设置为时间戳,它们会被触发吗?由于当前时间戳大于计时器服务的时间戳,它会立即被触发还是永远不会被触发?
此外,我们正试图根据事件时间对输入事件进行排序,方法是在基于处理时间的翻滚窗口中收集/缓冲输入事件,这样我们就不必丢弃延迟事件。有没有更好的解决方案来解决这个问题?
设置为过去时间戳的计时器将尽快触发。
有关排序,请参阅如何使用Flink对无序的事件时间流进行排序,以及如何使用FlinkSQL按事件时间对流进行排序。