0

即,如果并行度为2,则bolt 在2 个不同的服务器上运行,如果并行度为3,则bolt 在3 个不同的服务器上运行。这对我来说很重要,因为我不希望所有任务都只在一台服务器上运行,那太慢了。

4

1 回答 1

0

尝试通过增加配置参数“工人数量”(默认值为 1)

Config cfg = new Config();
cfg.setNumWorkers(...);

您还可以通过storm.yaml 配置参数限制每台主机的worker 数量supersior.slots.ports——对于每个端口,可以启动一个worker JVM,因此如果您只为此配置提供一个端口,则只会启动一个worker JVM。请注意,这可能会限制您可以运行的拓扑数量。单个工作 JVM 将仅执行来自单个拓扑的代码(以将拓扑彼此隔离)。

于 2016-09-01T16:30:28.340 回答