Hi -
I am using storm 0.9.1-incubating, and got a topology working locally that I am
interesting in testing scaling with multiple nodes on.
However, I when I set the number of workers on the topology config > 1, the
some bolts stop receiving input.
For example in my topology:
builder.setBolt("testBolt1", new TestRichBolt(1), 10)
.fieldsGrouping(counterId, new Fields("rsid", "word"));
builder.setBolt("testBolt2", new TestRichBolt(2), 10)
.fieldsGrouping("testBolt1", new Fields("rsid", "word"));
Which works fine when number of workers = 1, and when number of workers = 3,
then testBolt2 does not receive any input.
Any advice is appreciated.
Thanks
Tyson