风暴重新平衡命令不更新拓扑的工作器数

Question

我尝试为风暴 1.1.1 执行以下命令：

风暴 [拓扑名称] -n [number_of_worker]

命令成功运行，但辅助角色数保持不变。我也尝试减少工人的数量。那也没用。

我不知道发生了什么。任何指针都会有所帮助。

仅供参考：我已经实施了自定义计划？。是因为这个吗？

Answer 1

您可以随时查看该 CLI 背后的 Storm 源代码。或者编写重新平衡代码(针对 1.0.2 进行测试(：

RebalanceOptions rebalanceOptions = new RebalanceOptions();
rebalanceOptions.set_num_workers(newNumWorkers);
Nimbus.Client.rebalance("foo", rebalanceOptions);