Hi all,
my TOPOLOGY_MESSAGE_TIMEOUT_SECS was slightly to low. I got a fail for
a tuple and the spout just resend it.
One bolt normalizes a date in place in a field of the tuple. After the
spout resend the tuple, I got errors from the date parser because the
date was already normalized.
Since I currently have only one node, I know of course what happens. The
tuple was just the very same object that was already partially processed
when the timeout hit.
In a distributed setup I envisage the bolt to be on another machine with
a serialized copy of the spout's tuple such that changes to the tuple
are not reflected in the original. Would that be true?
I reckon from this that all processing in bolts needs to be idempotent
if I want to be able to replay failed tuples.
Is that true or am I doing something wrong?
Harald.
--
Harald Kirsch
Raytion GmbH
Kaiser-Friedrich-Ring 74
40547 Duesseldorf
Fon +49-211-550266-0
Fax +49-211-550266-19
http://www.raytion.com
