我正试图围绕我们的storm拓扑开发一些报告，我们想报告的一个指标是由于超时而失败的元组数。据我所知，当一个元组未能在超时长度之前完成时，storm将自动使其失败，但这似乎是在“幕后”发生的，我看不到区分超时失败和其他类型失败的方法。有没有办法暴露或捕捉这些信息？
yqkkidmi1#
如果您考虑storm的webui，那么对于每个螺栓，都有失败元组的计数。这些计数仅是手动失败的元组（即，通过 OutputCollector.fail(...) )不包括运行超时的元组。喷口有一个失败元组的总计数器。因此，您可以简单地将所有螺栓上手动失败的元组数相加，然后从全局喷口计数中减去if，得到超时的元组数。
OutputCollector.fail(...)
1条答案
按热度按时间yqkkidmi1#
如果您考虑storm的webui，那么对于每个螺栓，都有失败元组的计数。这些计数仅是手动失败的元组（即，通过
OutputCollector.fail(...))不包括运行超时的元组。喷口有一个失败元组的总计数器。因此，您可以简单地将所有螺栓上手动失败的元组数相加，然后从全局喷口计数中减去if，得到超时的元组数。