我们有一个通常运行良好的storm拓扑。我们在日志中没有错误,而且时间很快。然而,有时我们会得到“完全延迟”的峰值。

以下是各个螺栓:

所以我的问题是:是什么导致完整的延迟比单独的螺栓多得多?(如果有帮助,我们正在使用Microsoft spout和event hubs )。
发布于 2017-01-25 08:32:24
不,不是。每个组件的延迟不包括队列等待时间和工作进程之间的传输延迟。“完全延迟”表示元组树中的所有节点都已确认,因此它反映了树中最慢的路径。
顺便说一句,在幕后,“完全延迟”包括等待spout处理来自acker的ack的时间,如果你的spout在nextTuple中花费了很长时间,它将严重影响“完全延迟”。它已从STORM-1742修复,并将包含在下一个版本中。
希望这能有所帮助。
https://stackoverflow.com/questions/41832783
复制相似问题