Storm集群上的开发 ，Storm的内部原理，storm提交任务的过程

Posted 2020-09-29

storm提交任务的过程：

1.客户端通过storm提交topology

2.nimbus主节点创建本地topology任务目录。tmp

3.nimbus监控zookeeper心跳，计算工作量。

4.nimbus向zookeeper分配任务。

5.从节点监控zk的数据，一旦有新任务分配，启动任务topology。、

6.从zk上获取分配给自己的task任务，启动对应的worker进程。