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

Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/10/03 22:24:01 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16190481#comment-16190481 ] 

ASF GitHub Bot commented on SAMZA-1386:
---------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/samza/pull/277


> 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
>
> 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)