Thanks Abhishek. But this also implies that we can not have a loop ( of message processing stages) using Storm, right?
best, /Shahab On Mon, May 5, 2014 at 9:45 PM, Abhishek Bhattacharjee < [email protected]> wrote: > I don't think what you are trying to do is achievable. Data in storm > always move forward so you can't give it back to a bolt from which it > originated. That is a bolt can subscribe from bolts which were created > before it's creation. So, I think you can create another object of the A > bolt say D and then assign the o/p of C to D. > > > On Mon, May 5, 2014 at 8:11 PM, shahab <[email protected]> wrote: > >> Hi, >> >> I am trying to define a topology as following: >> S : is a spout >> A,B,C : are bolts >> --> : means emitting message >> >> S -->A >> A -->B >> B -->C >> C -->A >> >> I am declaring the Spouts and Bolts in the above order in my java code , >> first S, then A , B and finally C. >> >> I am using globalGrouping("BoltName", StreamID) for collecting messages >> to be collected by each bolt, >> >> The problem is that I receive an error, while defining bolt "A" saying >> "that subscribes from non-existent component [C]" . >> >> I guess the error is happening because component "C" is not defined yet! >> but what could be the solution to this? >> >> best, >> /Shahab >> >> >> >> >> >> >> > > > -- > *Abhishek Bhattacharjee* > *Pune Institute of Computer Technology* >
