Storm核心组件运行机制

 
Storm核心组件运行机制
 


Storm核心组件运行机制
 
1. storm集群启动后,nimbus进程、supervisor进程,分别向zookeeper进行注册

  • nimbus做为服务方,往zookeeper对应目录写job配置信息文件
  • supervisor做为客户端,监控zookeeper对应的目录

2. 通过strom client客户端提交job到nimbus,其中包括:

  • 指定spout、bolt实现类,以及并行数量
  • 各个spout、bolt的依赖关系和分组关系
  • Storm配置信息、运行方式(如:服务器提交或本地提交)

相关推荐