代码之家 › 专栏 › 技术社区 › kingluo

storm:bolt如何执行元组?

apache-storm

kingluo · 技术社区 · 7 年前

当 execute() 返回,螺栓将由下一个元组执行?如果螺栓未确认前一个元组,会发生什么情况?换句话说,我们可以在 执行() 退货?

如果螺栓长时间不确认一个元组,那么默认情况下,喷口将再次向下游发出父元组,螺栓将再次由同一元组执行,对吗?如果螺栓确认了一个已经被认为是喷口失败的旧元组,会发生什么?

1 回复 | 直到 7 年前

Stig Rohde Døssing 7 年前

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

是的,在execute返回后确认元组是可以的,只要您在合理的时间范围内(在消息超时过期和喷口再次发出根元组之前)这样做。

如果确认已过期的元组,则该元组无效。

推荐文章

Ajeesh · Apache Storm(1.2.1)运输异常断管

7 年前