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*
