Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.7.0
    • Component/s: None
    • Labels:
      None

      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.

        Attachments

        1. SAMZA-253.final.patch
          36 kB
          Martin Kleppmann
        2. SAMZA-253.3.patch
          36 kB
          Martin Kleppmann
        3. SAMZA-253.1.patch
          18 kB
          Martin Kleppmann

          Issue Links

            Activity

              People

              • Assignee:
                martinkl Martin Kleppmann
                Reporter:
                martinkl Martin Kleppmann
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: