You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Pradeep Badiger <Pr...@fico.com> on 2015/09/17 21:32:52 UTC

Spout fail() called immediately on local cluster

Hi,

I am trying to test a topology on a local cluster. The first bolt emits 10 messages for the 1 message from the spout. Out of these 10 messages 5th message fails. This causes the fail() method on the spout to be called immediately.

But this is not the behavior when in deploy and run it in a distributed mode. The fail gets called when all the 10 messages are completed.

Can someone help me with this behavior?

Thanks,
Pradeep V.B.


This email and any files transmitted with it are confidential, proprietary and intended solely for the individual or entity to whom they are addressed. If you have received this email in error please delete it immediately.