There is no ack() or fail() on a BaseRichBolt. I'm not sure I understand.
On Fri, Apr 18, 2014 at 11:24 PM, 羅以豪 <[email protected]> wrote: > Hi guys, I've been stuck with this problem for days. > > I run storm 0.9.0.1 and I also follow some rules from official guide for > > message handle, such followings > > - no time out for tuple > - spout and bolts are extending BaseRichSpout and BaseRichBolt > respectively. > - sure that give a message Id(object ID) for each tuple. > > I have a spout and a bolt in topology across two nodes > > and problem happened when I submit the topology to storm > > spout's fail function called immediately when emits the tuple > > and ack() or fail() were called in bolt but spout didn't receive anything > > it seems the message handle mechanism out of function but I have no > > idea. Does someone has the some experience? >
