I think you are a little confused about the difference between failing
tuples and skipping bolts. Here's a quick rundown:

Let's say your spout has emitted a tuple t. BaseBasicBolt has just received
t0, which is a tuple anchored to t.

If you decide to emit nothing and return from execute(), t0 will be acked.
If t0 was the last pending tuple anchored to t, t will be acked on the
spout (marked as "done", so it won't be replayed).

If you instead throw FailedException t is marked as failed, and the spout
will likely replay it.

If you emit any tuples they will automatically be anchored to t. This means
that the new tuples must also succeed before t gets acked.

So here's the answers to your questions:

The correct way to ack a tuple from a BaseBasicBolt is to not throw
FailedException. Unless you throw FailedException, the tuple will be acked.
The correct way to fail a tuple from a BaseBasicBolt is to throw
FailedException.

Also because it seems like this is what you're actually asking: If you have
a topology like Spout -> BasicBolt1 -> BasicBolt2 and you have a tuple t1
in BasicBolt1 and you want to skip BasicBolt2, BasicBolt1 simply shouldn't
emit any tuples while running execute() for t1.

I hope this helps.

2017-11-20 15:39 GMT+01:00 Hannum, Daniel <daniel_han...@premierinc.com>:

> Hi,
>
>
>
> I’m trying to get clear on how to handle various cases in my BaseBasicBolt.
>
>
>
> So far, I just have each bolt emit more tuples, pretty standard. But I
> still do that for the last bolt in the topology. I’m not sure I should do
> that. Seems dirty.
>
>
>
> Now, I have a case where I want a bolt to fail a tuple (skip all bolts
> after). I read that I should just return without emitting any tuples and
> that functions as a fail. That seems odd to me, that I should emit tuples
> at the end of my topology for success even when they go nowhere, but not
> emit anything to show failure.
>
>
>
> And then there’s always FailedException. Maybe I should forget all of this
> and just throw that if I want to fail the tuple.
>
>
>
> So what is the correct way to
>
>    1. Ack a tuple properly in the last bolt
>    2. Fail a tuple in the middle
>
>
>
> Thanks!
>

Reply via email to