worker根据分配的tasks信息,启动多个executor线程,同时实例化spout、bolt、acker等组件,此时,等待所有connections(worker和其它机器通讯的网络连接)启动完毕,此storm-cluster即进入工作状态。
除非显示调用kill topology,否则spout、bolt等组件会一直运行。
主要过程如下图所示:
结语以上,基本阐述了storm的基础框架,但未涉及trident机制,也基本回答了问题1。
终。
worker根据分配的tasks信息,启动多个executor线程,同时实例化spout、bolt、acker等组件,此时,等待所有connections(worker和其它机器通讯的网络连接)启动完毕,此storm-cluster即进入工作状态。
除非显示调用kill topology,否则spout、bolt等组件会一直运行。
主要过程如下图所示:
结语以上,基本阐述了storm的基础框架,但未涉及trident机制,也基本回答了问题1。
终。
内容版权声明:除非注明,否则皆为本站原创文章。
转载注明出处:https://www.heiqu.com/f5a961e4a1a6e8eb0639985c9516170b.html