Storm一个executor里运行多个task是为了rebalance

默认情况下下,一个executor运行一个component,即一个task,但有时会指定多个task:

1
builder.setBolt(""new XxBolt()).setNumTasks(2);

这是为了rebalance命令。

原文地址:https://www.cnblogs.com/lishouguang/p/4559211.html