1.给topology增加worker
2.增加executor与task task是Storm中进行计算的最小运行单位,表示是spout或者bolt的运行实例。在supervisor中,运行task的进程称为worker。 supervisor节点上可以运行非常多的worker进程,一般在一个进程中是可以启动多个线程的,所以我们可以在worker中运行多个线程,这些线程称为executor,在executor中运行task。 这样的话就可以提高Storm的计算能力。总结一下:worker > executor > task。
要想提高Storm的并行度可以从三个方面来改造:
worker(进程) > executor(线程) > task(实例) 增加worker进程,增加executor线程,增加task实例。 setNumWorker、setNumTask来提高Storm的并发度。