[SAMZA-2293] Propagate the watermark future to StreamOperatorTask correctly

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3
• Assignee: Bharath Kumarasubramanian
• Reporter: Bharath Kumarasubramanian
• Created: 07/Aug/19 00:52
• Updated: 07/Nov/19 00:06
• Resolved: 07/Aug/19 02:31

Description

Currently, we don't return the chained future from OnMessageAsync and aggregateWatermark to StreamOperatorTask correctly. Due to this, any errors in propagate watermark will not be propagated to the container correctly.

Issue Links

• links to: GitHub Pull Request #1129