Why not break up nextTuple into several iterations so the task has a chance to send its heartbeat?
On Mon, Oct 20, 2014 at 5:13 AM, [email protected] <[email protected]> wrote: > > Thank you for quick response. > > I iterator over a big set, so it takes much time to finish in the > nextTuple method. > > > > *From:* Itai Frenkel <[email protected]> > *Date:* 2014-10-20 17:10 > *To:* user <[email protected]> > *Subject:* Re: how can I send a heartbeat to supervisor manually? > > Could you please elaborate "it takes too much time to finish" ? For > example, does the emit method blocks due to pushback ? > ------------------------------ > *From:* [email protected] <[email protected]> > *Sent:* Monday, October 20, 2014 12:06 PM > *To:* user > *Subject:* how can I send a heartbeat to supervisor manually? > > how can I send a heartbeat to supervisor manually? > In my spout, I emit many tuples in a loop, it takes so much time to > finish. This cause the supervisor thinks the worker is dead and reassign > the job . > so how can I send a heartbeat to supervisor manually to inform supervisor > that the worker is alive ? >
