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 配置说明