[SAMZA-253] Consensus shutdown API

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.7.0
• Assignee: Martin Kleppmann
• Reporter: Martin Kleppmann
• Created: 28/Apr/14 16:51
• Updated: 20/May/14 17:46
• Resolved: 20/May/14 17:46

Description

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.

Issue Links

• is related to: SAMZA-23 TaskInstance commits for all TaskCoordinator.commit calls
• relates to: SAMZA-179 Support a way to shutdown when a task is caught up