我正在storm拓扑中运行许多并行请求,并已将topology.max.spout.pending设置为100。我的一些请求正在超时(不是storm元组超时,而是由我的应用程序为ach请求设置的显式超时)。我使用的是锚定元组,所以它们应该被确认。现在我怀疑在某个时刻,#个挂起的元组到达topology.max.spout.pending,这会导致其他请求等待。如何实时打印挂起的元组数?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!