gpt4 book ai didi

java - Apache Storm : What does the OutputCollector. fail() 方法怎么办?

转载 作者:行者123 更新时间:2023-11-30 07:57:16 24 4
gpt4 key购买 nike

使用BaseRichBolt时,有什么区别

_collector.fail(tuple)

_collector.ack(tuple)

它是否像超时一样导致元组被重新发送?或者它只是丢弃元组。 If So fail 方法和使用 ack 有什么区别?

最佳答案

ack() 确认元组,即告诉 Storm 元组已成功处理。

fail() 使元组失败,即告诉 Storm 无法成功处理元组,因此 Storm 稍后将重试此元组(即原始源元组)将在某个时候重新处理)。它基本上是一种快速失败机制——如果您没有在超时时间内确认一个元组,它也会失败。

关于java - Apache Storm : What does the OutputCollector. fail() 方法怎么办?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41489457/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com