Bharath Kumarasubramanian created SAMZA-2329:
------------------------------------------------
Summary: Chain watermark future to the result future in
onMessageAsync
Key: SAMZA-2329
URL: https://issues.apache.org/jira/browse/SAMZA-2329
Project: Samza
Issue Type: Bug
Reporter: Bharath Kumarasubramanian
Assignee: Bharath Kumarasubramanian
Currently, we don't chain the watermark future to the result future inside
onMessageAsync and return the result future. It is possible for the watermark
future to throw exception and this can get swallowed and not propagate to samza
core.
We need to chain the watermark future to the result future so that any
exception inside propagating watermark gets bubbled up correctly.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
