我想看看每个螺栓的性能，并决定平行度的数量。在storm ui中有几个字段很混乱，如果您能告诉我，我会很高兴的。容量（最后10米）-单个执行器在最后10分钟内每秒的平均容量？例如，如果capcity为1.2，是否意味着单个执行者平均每秒处理1.2条消息？执行延迟和处理延迟-是平均值还是最后处理的消息的值？它们之间有什么区别？它们和容量有什么区别？
hrirmatl1#
我发现了一篇描述storm ui的好文章。您可以通过以下链接访问：http://www.malinga.me/reading-and-understanding-the-storm-ui-storm-ui-explained/所以，我们有：容量（最后10米）-如果此值在1.0左右，则相应的螺栓将以最快的速度运行，因此您可能需要增加螺栓的平行度。这是（执行次数*平均执行延迟）/测量时间。execute latency（ms）–一个元组在execute方法中花费的平均时间。execute方法可以在不发送元组的ack的情况下完成。处理延迟（ms）–在第一次接收到元组后，确认元组所需的平均时间。连接、聚合或批处理的螺栓在收到多个其他元组之前不能确认元组。另外，我发现storm ui rest api的文档对于理解字段的含义非常有用：https://github.com/apache/storm/blob/master/storm-ui-rest-api.md
1条答案
按热度按时间hrirmatl1#
我发现了一篇描述storm ui的好文章。您可以通过以下链接访问：http://www.malinga.me/reading-and-understanding-the-storm-ui-storm-ui-explained/
所以，我们有：
容量（最后10米）-如果此值在1.0左右，则相应的螺栓将以最快的速度运行，因此您可能需要增加螺栓的平行度。这是（执行次数*平均执行延迟）/测量时间。
execute latency（ms）–一个元组在execute方法中花费的平均时间。execute方法可以在不发送元组的ack的情况下完成。
处理延迟（ms）–在第一次接收到元组后，确认元组所需的平均时间。连接、聚合或批处理的螺栓在收到多个其他元组之前不能确认元组。
另外，我发现storm ui rest api的文档对于理解字段的含义非常有用：https://github.com/apache/storm/blob/master/storm-ui-rest-api.md