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

Reply via email to