本文主要是介绍ContinuousEventTimeTrigger触发细节探究,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
背景
现有业务需要在同一个页面展示全天人次和分时人次,全天和分时对应两个任务,消费同一个topic,两者都使用ContinuousEventTimeTrigger,每隔30s trigger window的计算,两任务operator的背压都是0,那么现在问题来了,如果两个任务间隔10s先后启动,那么之后这两个任务的trigger的时间点是相同的吗?
个人误解
误认为任务触发的时间为任务启动时间+n*trigger interval,即任务的触发时间和任务的启动时间有关,如下图
源码正解
ReducingState
ContinuousE
这篇关于ContinuousEventTimeTrigger触发细节探究的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!