You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:08:00 UTC

[jira] [Created] (SAMZA-1494) Flush operator state on end of stream

Prateek Maheshwari created SAMZA-1494:
-----------------------------------------

             Summary: Flush operator state on end of stream
                 Key: SAMZA-1494
                 URL: https://issues.apache.org/jira/browse/SAMZA-1494
             Project: Samza
          Issue Type: Bug
            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)