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

Posted to commits@samza.apache.org by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:32:00 UTC

[jira] [Updated] (SAMZA-1386) Inline End-of-stream and Watermark logic inside OperatorImpl

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

Xinyu Liu updated SAMZA-1386:
-----------------------------
    Fix Version/s: 0.14.0

> Inline End-of-stream and Watermark logic inside OperatorImpl
> ------------------------------------------------------------
>
>                 Key: SAMZA-1386
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1386
>             Project: Samza
>          Issue Type: Bug
>    Affects Versions: 0.14.0
>            Reporter: Xinyu Liu
>            Assignee: Xinyu Liu
>             Fix For: 0.14.0
>
>
> Currently both EOS and Watermark aggregation/population logic is inside TaskInstance. Since watermark handling logic is in OperatorImpl, it makes sense to consolidate them together inside OperatorImpl, and make it feasible to provide user API to emit watermarks.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)