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.
