我尝试对storm 1.1.1执行以下命令：storm[topologyname]-n[工人人数]命令成功运行，但工作进程数保持不变。我也试着减少工人的数量。那也没用。我不知道发生了什么事。任何指针都会有帮助。仅供参考：我已经实现了自定义调度？。是因为这个吗？
mmvthczy1#
您可以随时查看该cli后面的storm源代码。或对重新平衡进行编码（根据1.0.2进行测试）：
RebalanceOptions rebalanceOptions = new RebalanceOptions(); rebalanceOptions.set_num_workers(newNumWorkers); Nimbus.Client.rebalance("foo", rebalanceOptions);
1条答案
按热度按时间mmvthczy1#
您可以随时查看该cli后面的storm源代码。或对重新平衡进行编码（根据1.0.2进行测试）：