官术网_书友最值得收藏!

Storm architecture and its components

Let's discuss Storm architecture and how it works. The following figure depicts the Storm cluster:

  • The Nimbus node acts as the master node in a Storm cluster. It is responsible for analyzing topology and distributing tasks to different supervisors as per their availability. Also, it monitors failure; if one of the supervisors dies, it redistributes the tasks among available supervisors. The Nimbus node uses Zookeeper to keep track of tasks to maintain it's state. If the Nimbus node fails, it can be restarted so that it reads the state of Zookeeper and starts from same point where it failed earlier.
  • Supervisors act as slave nodes in the Storm cluster. One or more workers, that is, JVM processes, can run in each supervisor node. A supervisor coordinates with workers to complete the tasks assigned by Nimbus node. In the case of worker process failure, the supervisor finds available workers to complete the tasks.
  • A worker process is a JVM running in a supervisor node. It has executors. There can be one or more executors in a worker process. A worker coordinates with an executor to finish up the task.
  • An executor is a single thread process spawned by a worker. Each executor is responsible for running one or more tasks.
  • A task is a single unit of work. It performs actual processing on data. It can be either a spout or a bolt.
  • Apart from previous processes, there are two important parts of a Storm cluster; they are logging and Storm UI. The logviewer service is used to debug logs for workers and supervisors on Storm UI.
主站蜘蛛池模板: 清河县| 沙湾县| 来安县| 牡丹江市| 泸溪县| 个旧市| 长白| 辽宁省| 拜泉县| 海宁市| 三原县| 博乐市| 马尔康县| 定边县| 呼图壁县| 南开区| 玉环县| 仙桃市| 贺州市| 资兴市| 宜阳县| 双城市| 彰化市| 水富县| 桐梓县| 阳信县| 诏安县| 南部县| 都匀市| 文登市| 衢州市| 马边| 舞钢市| 中宁县| 新余市| 临洮县| 安溪县| 修武县| 昭通市| 静乐县| 阆中市|