Storm topology求教?

Question

builder.setSpout("spout",new RandomSentenceSpout(),5).setNumTasks(7);5和7分别代表什么?

Answer 1

5代表 ：5个初始执行线程（executor），这个东西是由worker生成的线程。在 executor 中可能会有一个或者多个 task，这些 task 都是为同一个组件（spout 或者 bolt）服务的。

7代表：7个task任务的数目，task 是实际执行数据处理的最小工作单元（注意，task 并不是线程）