Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
In the current implementation, StreamProcessor shutdown sequence is the following:
- Stop the SamzaContainer.
- In the SamzaContainer shutdown callback handler, stop the JobCoordinator.
- 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.