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

Posted to commits@samza.apache.org by "Hai Lu (Jira)" <ji...@apache.org> on 2019/11/07 00:06:03 UTC

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

     [ https://issues.apache.org/jira/browse/SAMZA-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hai Lu updated SAMZA-2329:
--------------------------
    Fix Version/s: 1.3

> 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
>            Priority: Major
>             Fix For: 1.3
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> 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)