在 Apache Storm 中重新平衡执行器
Rebalancing executors in Apache Storm
我正在尝试重新平衡 运行 Apache Storm (0.9.5) 拓扑中螺栓的执行程序数量。当我对 Nimbus 节点 ./storm rebalance MyTopology -n 2 -e GreenBolt=4
执行命令时,它接受命令行输入,但当我在 Storm UI.
中查看时,执行者的数量没有改变
有没有我不知道的限制,比如重新平衡不能增加执行者的总数,只能将它们从一个螺栓移动到另一个螺栓?
您总是需要比执行者拥有更多(或相等数量)的任务。由于任务数量是固定的,您需要设置比初始执行器更大的初始数量,以便能够在运行时扩展执行器的数量。可以看到task的数量,最大executor数量:
#executors <= #numTasks
详情请看这里:https://storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html
我正在尝试重新平衡 运行 Apache Storm (0.9.5) 拓扑中螺栓的执行程序数量。当我对 Nimbus 节点 ./storm rebalance MyTopology -n 2 -e GreenBolt=4
执行命令时,它接受命令行输入,但当我在 Storm UI.
有没有我不知道的限制,比如重新平衡不能增加执行者的总数,只能将它们从一个螺栓移动到另一个螺栓?
您总是需要比执行者拥有更多(或相等数量)的任务。由于任务数量是固定的,您需要设置比初始执行器更大的初始数量,以便能够在运行时扩展执行器的数量。可以看到task的数量,最大executor数量:
#executors <= #numTasks
详情请看这里:https://storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html