[SAMZA-1322] Propagate watermark messages

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.14.0
• Fix Version/s: 0.14.0
• Assignee: Xinyu Liu
• Reporter: Xinyu Liu
• Created: 06/Jun/17 16:38
• Updated: 21/Nov/17 19:36
• Resolved: 21/Nov/17 19:36

Description

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.

Issue Links

• is depended upon by: SAMZA-1260 Support Control Messages Across Intermediate Streams