The nimbus will detect that the task has timed out and reassign the worker
process.

On Tue, Jan 27, 2015 at 2:11 AM, Sajith <[email protected]> wrote:

> Hi all,
>
> Can someone please clarify what action does supervisor takes when a
> certain tasks fails within a worker process?
>
> Also, if some other task is emitting tuples to the failed task how does
> the emitting task handle the failure of receiving task?
>
> Is there a way to capture and handler such case?
>

Reply via email to