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/06/06 16:38:18 UTC

[jira] [Created] (SAMZA-1322) Propagate watermark messages

Xinyu Liu created SAMZA-1322:
--------------------------------

             Summary: Propagate watermark messages
                 Key: SAMZA-1322
                 URL: https://issues.apache.org/jira/browse/SAMZA-1322
             Project: Samza
          Issue Type: Task
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu


TaskInstance will aggregate watermark messages based on counting the upstream tasks, and calculate the result watermark based on the following equation:

InputWatermark = min { OutputWatermark(task) for each task in upstream tasks }

Then it will deliver the water to the task. The task will process the watermark and finally send it again to downstreams based on stream graph topology.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)