> what is the number of workers set in topology definition. topology.workers was set to 1. So I resubmitted the topology with topology.workers to 5 and parallelismHint 5 for the spout at the end for the aggregate
final TridentState wordCounts = topology.newStream("kafka", kafkaSpout) .parallelismHint(5) .shuffle() // .each(new Fields("str"), new PrintFilter()) .each(new Fields("str"), new Split(), new Fields("word")) .groupBy(new Fields("word")) .persistentAggregate(new MemoryMapState.Factory(), new Count(), new Fields("aggregates_words")).parallelismHint(5); Thanks, Josh On Fri, Jul 18, 2014 at 11:11 AM, Susheel Kumar Gadalay <skgada...@gmail.com > wrote: > what is the number of workers set in topology definition. > > On 7/18/14, Josh J <joshjd...@gmail.com> wrote: > > Hi, > > > > I started my topology with a single supervisor. I then added two more > > supervisor nodes and tried the storm rebalance option in the storm ui. > > Though the topology doesn't seem to rebalance or utilize the new > supervisor > > nods. I see in the storm ui it does recognize and register the additional > > two supervisor nodes. though the topology is not rebalancing to utilize > the > > additional capacity. screenshots attached, any suggestions? > > > > Thanks, > > Josh > > >