Storm-源码分析-Stats (backtype.storm.stats)
会发现, 现在storm里面有两套metrics系统, metrics framework和stats framework 并且在所有地方都是同时注册两套, 貌似准备用metrics来替代stats, 但当前版本UI仍然使用stats 这个模块统计的数据怎么被使用, 1. 在worker中, 会定期调用do-executor-heartbeats去往zk同步hb 可以看到, stats也会作为hb的一部分被同步到zk上 (defnk do-executor-heartbeats [worker :executors nil] ;; stats is how we know what executors are assigned to this worker (let [stats (if-not executors (into {} (map (fn [e] {e nil}) (:executors worker))) (->> executors (map (fn [e] {(executor/get-executor-id e) (executor/render-st...