[jira] [Updated] (SAMZA-253) Consensus shutdown API

["Martin Kleppmann (JIRA)" <ji...@apache.org>]

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

Martin Kleppmann updated SAMZA-253:
-----------------------------------

    Attachment: SAMZA-253.1.patch

Attached patch in which just the shutdown API is extracted from SAMZA-179.

- New RB: https://reviews.apache.org/r/20802/
- I'm also adding some comments to SAMZA-179's RB: https://reviews.apache.org/r/19384/

> Consensus shutdown API
> ----------------------
>
>                 Key: SAMZA-253
>                 URL: https://issues.apache.org/jira/browse/SAMZA-253
>             Project: Samza
>          Issue Type: New Feature
>            Reporter: Martin Kleppmann
>            Assignee: Martin Kleppmann
>             Fix For: 0.7.0
>
>         Attachments: SAMZA-253.1.patch
>
>
> Extracted from SAMZA-179.
> At the moment, TaskCoordinator.shutdown() can be called by any task, and immediately shuts down the container as soon as the current message has finished processing. That is appropriate in some cases, but not always. Sometimes, what we actually want is for each task to vote that it's ready to shut down, and for the container to be shut down when all tasks within that container have voted.
> A first implementation of this is on https://reviews.apache.org/r/19384/ but it's mixed up with several other concerns. This ticket is to extract only the shutdown API changes (TaskCoordinator.ShutdownMethod) from that patch, and to address the relevant comments made on that RB.



--
This message was sent by Atlassian JIRA
(v6.2#6252)