You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Bharath Kumarasubramanian (Jira)" <ji...@apache.org> on 2019/09/23 22:39:00 UTC

[jira] [Created] (SAMZA-2329) Chain watermark future to the result future in onMessageAsync

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)