Aditya created SAMZA-1652:
-----------------------------

             Summary: Window high level API: End Of Stream message does not 
fire Window trigger
                 Key: SAMZA-1652
                 URL: https://issues.apache.org/jira/browse/SAMZA-1652
             Project: Samza
          Issue Type: Bug
            Reporter: Aditya


StreamOperatorTask has code to handle EOS but EOS message itself is not passed 
to  StreamOperatorTask as it does not implement EndOfStreamListenerTask. 
[~jagadish1...@gmail.com] is looking into it.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to