yes, that's what I've done. thank you. From: Nathan Leung Date: 2014-10-20 21:28 To: user Subject: Re: Re: how can I send a heartbeat to supervisor manually? 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 Date: 2014-10-20 17:10 To: user 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 ?
