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

Kinesis Spout失败(Apache Storm)

apache-storm

n00b · 技术社区 · 10 年前

我一直在对我们的Apache Storm拓扑进行性能测试,并注意到驱动器喷口的“失败”计数非常高(几乎有三分之一的元组被确认)。这个值是多少?

它们是否是在超时值内未能在拓扑中端到端处理的元组。是否有方法验证失败计数是由于处理超时造成的?

1 回复 | 直到 10 年前

Matthias J. Sax 10 年前

是的,失败计数显示失败(即,不是端到端处理的)元组的数量。元组失败可能有两个原因。用户代码(通过调用 Collector.fail(...) )或者如果元组超时。

因此,如果不涉及手动失败,则元组失败的原因是超时。Storm中的默认超时为30秒,可以通过 Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS .

推荐文章

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

7 年前

TechCrap · apache storm与python混合拓扑-ModuleNotFoundError:没有名为“storm”的模块

7 年前

Aniruddha · 在storm群集上提交拓扑时出错

7 年前

kingluo · storm:bolt如何执行元组?

7 年前

Ahmad Osama · 将数据从Apache Storm插入Azure Cosmos DB

8 年前

Saurabh · 在Apache Storm中使用与多个螺栓相同的类

8 年前

Keshore Durairaj · 实时流数据聚合

8 年前

Siva S · Apache strom—包的返回类型。暴风雨元组不存在

8 年前

Ryanqy · 监管在风暴中意味着什么?

8 年前

jdowdell · 流处理架构:未来事件影响过去结果

8 年前