Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
即,如果并行度为2,则bolt 在2 个不同的服务器上运行,如果并行度为3,则bolt 在3 个不同的服务器上运行。这对我来说很重要,因为我不希望所有任务都只在一台服务器上运行,那太慢了。
尝试通过增加配置参数“工人数量”(默认值为 1)
Config cfg = new Config(); cfg.setNumWorkers(...);
您还可以通过storm.yaml 配置参数限制每台主机的worker 数量supersior.slots.ports——对于每个端口,可以启动一个worker JVM,因此如果您只为此配置提供一个端口,则只会启动一个worker JVM。请注意,这可能会限制您可以运行的拓扑数量。单个工作 JVM 将仅执行来自单个拓扑的代码(以将拓扑彼此隔离)。
supersior.slots.ports