Bharath Kumarasubramanian created SAMZA-2293:
------------------------------------------------
Summary: [Bug] Propagate the watermark future to
StreamOperatorTask correctly
Key: SAMZA-2293
URL: https://issues.apache.org/jira/browse/SAMZA-2293
Project: Samza
Issue Type: Improvement
Reporter: Bharath Kumarasubramanian
Assignee: Bharath Kumarasubramanian
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.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
