[SAMZA-2329] Chain watermark future to the result future in onMessageAsync

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3
• Assignee: Bharath Kumarasubramanian
• Reporter: Bharath Kumarasubramanian
• Created: 23/Sep/19 22:38
• Updated: 07/Nov/19 00:05
• Resolved: 25/Sep/19 07:53

Description

Currently, we don't chain the watermark future to the result future inside onMessageAsync and return the result future. It is possible for the watermark future to throw exception and this can get swallowed and not propagate to samza core.

We need to chain the watermark future to the result future so that any exception inside propagating watermark gets bubbled up correctly.

Issue Links

• links to: GitHub Pull Request #1167