storm:bolt如何执行元组?

问题描述 投票:0回答:1

execute()返回时,螺栓将由下一个元组执行?如果螺栓没有响应前一个元组会发生什么?换句话说,我们可以在execute()返回后获取元组吗?

如果螺栓长时间没有响一个元组,那么默认情况下,spout会再次向下游发出父元组,并且螺栓将再次由同一个元组执行,对吧?如果螺栓确认一个已被认为是喷嘴失效的旧元组会发生什么?

apache-storm
1个回答
0
投票

如果你没有在螺栓中确认输入元组,那么spout可能会再次发出根元组。

是的,只要你在一个合理的时间范围内(在消息超时到期并且spout再次发出根元组之前)执行它,就可以在执行返回后确认元组。

如果你确定一个已经过期的元组,它就没有效果了。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.