You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Boris Shkolnik (JIRA)" <ji...@apache.org> on 2017/06/22 17:27:00 UTC

[jira] [Assigned] (SAMZA-1341) Halt task executions on debounceTimer shutdown.

     [ https://issues.apache.org/jira/browse/SAMZA-1341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Boris Shkolnik reassigned SAMZA-1341:
-------------------------------------

    Assignee: Shanthoosh Venkataraman

> Halt task executions on debounceTimer shutdown.
> -----------------------------------------------
>
>                 Key: SAMZA-1341
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1341
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Shanthoosh Venkataraman
>            Assignee: Shanthoosh Venkataraman
>            Priority: Minor
>
> When samza container shutdown time is longer than taskShutdownMs, streamProcessor shuts down jobCoordinator, zkController etc.
> Handler tasks for events added to debounceTimer queue before jobCoordinator.shutdown gets triggered after the shutdown. Example of such events are jobModelVersionChange, jobModelAvailable etc. Acting on these events after shutdown causes zkClient session closed exceptions. Ideally, these tasks should be discarded.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)