Shanthoosh Venkataraman created SAMZA-1341:
----------------------------------------------
Summary: Halt task executions on debounceTimer shutdown.
Key: SAMZA-1341
URL: https://issues.apache.org/jira/browse/SAMZA-1341
Project: Samza
Issue Type: Bug
Reporter: Shanthoosh Venkataraman
Priority: Minor
When samza container shutdown time is longer than taskShutdownMs,
streamProcessor shuts down jobCoordinator, zkController etc.
Handler tasks for events added to debounceTimer queue before
jobCoordinator.shutdown gets triggered after the shutdown. Example of such
events are jobModelVersionChange, jobModelAvailable etc. Acting on these events
after shutdown causes zkClient session closed exceptions. Ideally, these tasks
should be discarded.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
