Database Reference
In-Depth Information
Rebalancing using the CLI
The second option for rebalancing is using the Storm CLI. The command for this is as fol-
lows:
storm rebalance mystormtopology -n 5 -e my-spout=3 -e
my-bolt=10
Here, -n specifies the number of workers allocated to the topology post-rebalance, -e
my-spout refers to parallelism assigned to the spout, and similarly -e my-bolt refers
to parallelism to be assigned to the bolt. In the preceding command, we executed the Storm
shell from the bin directory under the Storm installation JAR, and while rebalancing the
Storm topology by changing the parallelism of the spout and bolts as well.
The changes to the execution of the preceding commands can be verified from the Storm
UI.
Search WWH ::




Custom Search