Storm UI說明

1、Storm ui 首頁主要分爲4塊: Cluster Summary，Topology summary，Supervisor summary，Nimbus Configuration

Cluster Summary
 

Version: storm 版本號
Nimbus uptime: nimbus的運行時間
Supervisors: storm集羣中supervisor的數目
used slots: 使用了的slots數
free slots: 剩餘的slots數
total slots: 總的slots數（對應配置文件的supervisor.slots.ports 屬性配置的端口數,集羣的總和）
Executors：線程數
tasks: 運行的任務數

 

topology summary

Name: topology name
id: topology id (由storm系統生成)
status: topology的運行狀態，包括(ACTIVE, INACTIVE, KILLED, REBALANCING)
uptime: topology運行的時間
num workers: 運行的workers數
Num Exectors: workers 運行的線程數
num tasks: 運行的task數

 

supervisor summary

Id: 系統生成的 supervisor Id
host: supervisor(主機)的主機名
uptime: supervisor運行時間
slots: supervisor的端口數
used slots: 使用的端口數

 

Nimbus Configuration：nimbus 集羣中的配置文件信息

 

2、Topology Page

（1）Topology summary
（2）Topology actions
（3）Topology stats
（4）Spouts (All time)
（5）Bolts (All time)
（6）Topology Visualization
（7）Topology Configuration

 

 （1）Topology summary

Name: topology name
id: topology id (由storm系統生成)
status: topology的運行狀態，包括(ACTIVE, INACTIVE, KILLED, REBALANCING)
uptime: topology運行的時間
num workers: 運行的workers數
Num Exectors: workers 運行的線程數
num tasks: 運行的task數

（2）Topology actions

Topology 運行狀態，能夠手動更改狀態（ACTIVE, DEACTIVATE, KILLED, Rebalance）

（3）Topology stats

Window:時間窗口，顯示10m、3h、1d和all time的運行情況
Emitted: emit tuple數
Transferred :  transferred tuple數, 說下與emitted的區別：若是一task，emitted一個tuple到2個task中，則transferred tuple數是emitted tuple數的兩倍
complete latency: spout emitting 一個tuple到spout ack這個tuple的平均時間
Acked:成功 tuple數
Failed:失敗tuple數

注意事項：
emitted欄顯示的數字表示的是調用OutputCollector的emit方法的次數. 

transferred欄顯示的數字表示的是實際tuple發送到下一個task的計數. 

若是一個bolt A使用all group的方式(每個bolt都要接收到)向bolt B發射tuple, 此時bolt B啓動了5個task, 那麼trasferred顯示的數量將是emitted的5倍. 

若是一個bolt A內部執行了emit操做, 可是沒有指定tuple的接受者, 那麼transferred將爲0. 

有的bolt的execture方法中並無emit tuple, 可是storm ui中依然有顯示emitted, 主要是由於它調用了ack方法, 而該方法將emit ack tuple到系統默認的acker bolt. 所以若是anchor方式emit一個tuple, emitted通常會包含向acker bolt發射tuple的數量. 

另外collector.emit(new Values(xxx))和collector.emit(tuple, new Values(xxx)) 這兩種不一樣的emit方法也會影響後面bolt的emitted和transferred, 若是是前者, 則後續bolt的emited tuple  和transferred tuple這兩個值都是0, 由於前一個emit方法是非安全的, 再也不使用acker來進行校驗. 

（4）Spouts (All time)

Id: spout id

Executors：線程數

Emitted: emit tuple數

Transferred :  transferred tuple數,

complete latency: spout emitting 一個tuple到spout ack這個tuple的平均時間

Acked:成功 tuple數

Failed:失敗tuple數

Error Host： 發生錯誤的機器

Error Port: 發生錯誤的端口號

last error: 最近的錯誤數

（5）Bolts (All time)

Execute latency(ms) ： bolt 執行 execute 方法的平均時間

Executed: tuple 處理數

Process latency(ms):bolt收到一個tuple到bolt ack這個tuple的平均時間

（6）Topology Visualization  拓撲圖展現

（7）Topology Configuration 配置說明