Storm在Zookeeper中的目錄結構

/-{storm-zk-root}           -- storm在zookeeper上的根
  |                            目錄
  |
  |-/assignments            -- topology的任務分配信息
  |   |
  |   |-/{topology-id}      -- 這個下面保存的是每一個
  |                            topology的assignments
  |                            信息包括: 對應的
  |                            nimbus上的代碼目錄,全部
  |                            task的啓動時間,
  |                            每一個task與機器、端口的映射
  |
  |-/tasks                  -- 全部的task
  |   |
  |   |-/{topology-id}      -- 這個目錄下面id爲
  |       |                    {topology-id}的topology
  |       |                    所對應的全部的task-id
  |       |
  |       |-/{task-id}      -- 這個文件裏面保存的是這個
  |                            task對應的component-id:
  |                            多是spout-id或者bolt-id
  |
  |-/storms                 -- 這個目錄保存全部正在運行
  |   |                        的topology的id
  |   |
  |   |-/{topology-id}      -- 這個文件保存這個topology
  |                            的一些信息,包括topology的
  |                            名字,topology開始運行的時
  |                            間以及這個topology的狀態
  |                            (具體看StormBase類)
  |
  |-/supervisors            -- 這個目錄保存全部的supervisor
  |   |                        的心跳信息
  |   |
  |   |-/{supervisor-id}    -- 這個文件保存的是supervisor
  |                            的心跳信息包括:心跳時間,主
  |                            機名,這個supervisor上worker
  |                            的端口號運行時間
  |                            (具體看SupervisorInfo類)
  |
  |-/taskbeats              -- 全部task的心跳
  |   |
  |   |-/{topology-id}      -- 這個目錄保存這個topology的所
  |       |                    有的task的心跳信息
  |       |
  |       |-/{task-id}      -- task的心跳信息,包括心跳的時
  |                            間,task運行時間以及一些統計
  |                            信息
  |
  |-/taskerrors             -- 全部task所產生的error信息
      |
      |-/{topology-id}      -- 這個目錄保存這個topology下面
          |                    每一個task的出錯信息
          |
          |-/{task-id}      -- 這個task的出錯信息component

相關文章
相關標籤/搜索