When implementing a spout, is it expected that different threads may be
calling nextTuple() and ack()? That is, if ack() needs to clean up some
local state, does that state have to be held in a synchronized data
structure?

It seems like that would be necessary, but I've read (somewhere, having
trouble finding it now...) that individual Storm components are only
operated on by a single thread and therefore do not need to be thread-safe.

Am I missing a spot in the documentation that explains this?

Thanks,
Mark

Reply via email to