我正在尝试围绕Storm拓扑开发一些报告，我们要报告的一个指标是由于超时而失败的元组数。
据我了解，当Storm在超时长度之前未能完成时，它将自动使一个元组失败，但是这似乎是在“幕后”发生的，并且我看不到区分超时失败与其他类型失败的方法。
有什么办法可以暴露或捕获此信息？
如果考虑Storm的WebUI，则每个螺栓都有一个失败的元组计数。这些计数仅是OutputCollector.fail(...)螺栓的手动失败的元组（即通过失败），并且不包括遇到超时的元组。喷口有一个失败元组的整体计数器。因此，您可以简单地总结所有螺栓上的手动失败元组的数量，并从全局喷口计数中减去是否获得超时的元组数量。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句