Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1668

StreamProcessor shutdown waits indefinitely for SamzaContainer to stop.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None
    • None

    Description

      In the current implementation, StreamProcessor shutdown sequence is the following:

      1. Stop the SamzaContainer.
      2. In the SamzaContainer shutdown callback handler, stop the JobCoordinator.
      3. In JobCoordinator callback handler, trigger the shutdown sequence of LocalApplicationRunner.

      If there's a infinite loop(wait) in any step of SamzaContainer shutdown sequence, the whole StreamProcessor shutdown is stalled.

      Attachments

        Activity

          People

            spvenkat Shanthoosh Venkataraman
            spvenkat Shanthoosh Venkataraman
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: