Storm中的执行者数量

Question

我正在玩Storm.这是我正在使用的拓扑:

builder.setSpout("word", new RandomSentenceSpout(), 3);
builder.setBolt("exclaim1", new ExclamationBolt(), 6).shuffleGrouping("word");

我认为Storm会为这个拓扑产生9个执行器(3个喷口+ 6个螺栓),但是当我实际运行它时,我可以看到11个执行器正在运行.

那两个额外的执行者是什么？

Answer 1

您是否在拓扑中的其他位置设置 numTasks ？分享拓扑创建代码应该有助于回答。另外，您在本地或集群模式下运行它吗？执行者数总是小于或等于 NumTasks。 http://www.michael-noll.com/blog/2012/10/16/understanding-the-parallelism-of-a-storm-topology/这个博客很好地解释了storm中的并行性。