Navina Ramesh created SAMZA-1150:
------------------------------------

             Summary: Handling Error propagation between ZkJobCoordinator & 
DebounceTimer
                 Key: SAMZA-1150
                 URL: https://issues.apache.org/jira/browse/SAMZA-1150
             Project: Samza
          Issue Type: Bug
            Reporter: Navina Ramesh


Right now, I don't think we handle errors from any of the callback properly. As 
far as I can tell, most of the errors should cause the processor to stop and 
propagate the error to the user. But we need to carefully evaluate the various 
error scenarios.
Through this JIRA, we need to answer the following:
1. How to handle errors/exceptions thrown in the callbacks that are executed 
with the debounce timer?
2. Debounce timer has a category of tasks to run. What happens when one task 
fails? Do we cancel the other pending tasks, if any ? Does the ordering of the 
tasks matter at all? 




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to