[SAMZA-1354] Pass in typed control message into EndOfStreamManager.update() and WatermarkManager.update()

• 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: 28/Jun/17 23:42
• Updated: 21/Nov/17 19:34
• Resolved: 21/Nov/17 19:34

Description

From Yi's review feedback: Right now EndOfStreamManager.update() and WatermarkManager.update() takes in IncomingMessageEnvelope. It's better to pass in typed control message and ssp to it to avoid type cast.

Issue Links

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