[ https://issues.apache.org/jira/browse/SAMZA-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bharath Kumarasubramanian closed SAMZA-2293. -------------------------------------------- > Propagate the watermark future to StreamOperatorTask correctly > -------------------------------------------------------------- > > Key: SAMZA-2293 > URL: https://issues.apache.org/jira/browse/SAMZA-2293 > Project: Samza > Issue Type: Bug > Reporter: Bharath Kumarasubramanian > Assignee: Bharath Kumarasubramanian > Priority: Major > Time Spent: 20m > Remaining Estimate: 0h > > 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)