lakshmi-manasa-g opened a new pull request #1363:
URL: https://github.com/apache/samza/pull/1363


   **Bug fix**
   **Symptom:** No visible symptoms seen yet. Potential symptom is silent drop 
of exceptions in producer.flush.
   
   **Cause:** During producer.flush, all writers are closed. The 
CompletableFuture waiting on the writer.close catches only IOExceptions but the 
writers could throw any exception. This might result exceptions other than 
IOException not being bubbled up.
   
   **Changes:** Make CompletableFuture catch all "throwable"
   
   **API changes:** None
   
   **Upgrade Instructions:** None
   
   **Usage Instructions:** None


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to