On Wed, Mar 19, 2014 at 01:02:54PM -0400, Milinda Pathirage wrote: > How about adding a extra field (user id or job id) to data chunks and > use that field to distiguish tasks.
Milinda, that might work if I could send a "message" that this task is done, and no more input will come from spout. And it seems to be not trivial in case if topology is truly distributed (I could expect some messages after this "end" marker has been sent). Also, it seems that I can not "attach" a new spout to an existing topology, so looks like I have to start a new topology for a task. -- Eugene N Dzhurinsky
pgpBI92QH0UbE.pgp
Description: PGP signature
