> 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 <[email protected]
> wrote:
> what is the number of workers set in topology definition.
>
> On 7/18/14, Josh J <[email protected]> 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
> >
>
