Apache Storm:是否在主管节点上的至少一个工作人员上复制了拓扑?
Apache Storm: Is the topology replicated on atleast one worker on a Supervisor Node?
我刚刚开始学习 Apache Storm。我无法理解的一件事是整个拓扑是否被复制到主管节点上的至少一个工作进程上。如果是这种情况,那么拓扑中计算密集型的组件(并且可能提供更好的(性能)单独在一台机器上执行)是潜在的瓶颈吗?如果不是,我假设 Nimbus 以某种方式 "distributes" 部分拓扑结构跨集群。它如何知道如何优化 "distribute" 拓扑?
Storm 不复制拓扑。如果部署拓扑,所有执行程序线程将均匀分布在所有工作节点上(使用循环调度机制)。拓扑可以使用的工作节点数,可以通过 Config.setNumWorkers(int);
.
配置
如果您有一个计算密集型 Bolt,并且您希望确保将其部署到自己的工作人员,则需要实施自定义调度程序。见她了解更多详情:https://xumingming.sinaapp.com/885/twitter-storm-how-to-develop-a-pluggable-scheduler/
我刚刚开始学习 Apache Storm。我无法理解的一件事是整个拓扑是否被复制到主管节点上的至少一个工作进程上。如果是这种情况,那么拓扑中计算密集型的组件(并且可能提供更好的(性能)单独在一台机器上执行)是潜在的瓶颈吗?如果不是,我假设 Nimbus 以某种方式 "distributes" 部分拓扑结构跨集群。它如何知道如何优化 "distribute" 拓扑?
Storm 不复制拓扑。如果部署拓扑,所有执行程序线程将均匀分布在所有工作节点上(使用循环调度机制)。拓扑可以使用的工作节点数,可以通过 Config.setNumWorkers(int);
.
如果您有一个计算密集型 Bolt,并且您希望确保将其部署到自己的工作人员,则需要实施自定义调度程序。见她了解更多详情:https://xumingming.sinaapp.com/885/twitter-storm-how-to-develop-a-pluggable-scheduler/