apache-storm - Storm.yaml 的 supervisor.slots.ports 和 Config.setNumWorkers(#workers) 方法调用的对应关系

Question

其他 Storm 用户:

设置 Storm 集群的指南 ( https://github.com/nathanmarz/storm/wiki/Setting-up-a-Storm-cluster )
指示将 supervisor.slots.ports 配置属性设置为对于机器上的每个工作人员
你分配一个单独的端口。

我的理解是每个 worker 都是一个 JVM 实例，它监听来自 nimbus Controller 的命令。
因此，每个人都在单独的端口上监听是有道理的。

但是， backtype.storm.Config 上还有一个方法似乎允许定义工作人员的数量。如果对 setNumWorkers 的调用尝试设置的 worker 比您为 配置的端口数多怎么办？
那似乎会把事情搞砸。

对我来说唯一有意义的是 yaml 配置定义了 worker 数量的上限。
每个拓扑可能会请求为其分配一些工作程序。但是如果我提交了两个拓扑(到某个特定的集群)，每个
调用 Config.setNumWorkers(2)，那么我最好配置四个端口。

这是正确的想法吗？

提前致谢 ..
-克里斯

Answer 1

好吧，我认为上限猜测是正确的。我在我的笔记本电脑上设置了一个单机 Storm 集群，然后我构建了 ExclamationTopology(来自storm-starter)。我只设置了两个 worker ，但是 ExclamationTopology 调用了 > conf.setNumWorkers(3);

但是，当我查看 Storm UI 时，它告诉我“Num Workers”是 2。

因此，您在storm.yaml 文件中设置的似乎是一个上限，如果您要求的worker 数量超过您配置的端口数，那么您只会获得最大可用数量。

(警告:我刚开始接触这个东西，绝不是专家，所以我有可能错过了一些东西......但上面的报告是我观察到的。)