2017-04-24 45 views
0

關於風暴指標。我不明白髮送隊列到達率和接收隊列到達率之間的關係。 例如,當打開ACK時,如果噴口接收到一個元組,並且它發出一個元組。 RQ到達率:SQ到達率= 1:2?如何瞭解關於apache風暴干擾隊列的到達率

此外,如果系統不穩定。這個等式可能會改變?

非常感謝您的幫助?

回答

0

Storm中的Spout實例沒有接收隊列(只有一個發送隊列)?我假定你指的是螺栓?

雖然這是一個有點舊this article邁克爾諾爾給工人內部隊列很好的概述。

回答你的問題。隊列之間的比例不總是2:1。干擾隊列通過用戶可配置的topology.builtin.metrics.bucket.size.secs來平均報告其指標,所以這會掩蓋一些差異。此外,所有度量標準都受到由topology.stats.sample.rate配置變量設置的示例比率的影響 - 默認情況下,該比率僅爲傳輸元組的20%,這也會導致報告的數字爲關。另外,根據你的螺栓中的代碼,1個輸入元組可能會產生很多輸出元組,所以你必須考慮到你計算的任何比例。

你指的是你的問題中方程的穩定性。到達率不是基於任何排隊理論方程,而僅僅是在metric.bucket週期中放入隊列中的元組的數量除以週期長度(以秒爲單位)。但是,Storm確實報告了隊列逗留時間度量。這是基於一個非常簡單的排隊論方程,對於不穩定隊列系統是不可靠的,應該避免。

+0

非常感謝。抱歉沒有及時回覆。 Storm中的Spout實例具有用於接收元組形式acker實例的接收隊列。因此,噴口收到的元組數量應該等於它發送的數量。 – wendyhusband