[ https://issues.apache.org/jira/browse/SAMZA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jagadish closed SAMZA-1494. --------------------------- > Flush operator state on end of stream > ------------------------------------- > > Key: SAMZA-1494 > URL: https://issues.apache.org/jira/browse/SAMZA-1494 > Project: Samza > Issue Type: Sub-task > Reporter: Prateek Maheshwari > Assignee: Jagadish > Fix For: 0.14.0 > > > Stateful operators should flush all buffered state when end of stream is > reached. Otherwise the container may shut down with open windows and lead to > message loss. > As of 0.14, only window operator needs to do this. When we add > outer/left/right joins they'll need to do it as well. -- This message was sent by Atlassian JIRA (v6.4.14#64029)