[
https://issues.apache.org/jira/browse/SAMZA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034858#comment-17034858
]
Sanil Jain commented on SAMZA-2057:
-----------------------------------
[~xinyu] Thanks for the clarification, I now understand that it is desired to
not emit the current window-pane if the window is not complete yet (according
to wall clock time)
> Window operator on encountering end of stream does not emit the last window
> pane
> --------------------------------------------------------------------------------
>
> Key: SAMZA-2057
> URL: https://issues.apache.org/jira/browse/SAMZA-2057
> Project: Samza
> Issue Type: Bug
> Reporter: Sanil Jain
> Priority: Minor
>
> On encountering EndOfStreamMessage a shutdown sequence is triggered, there is
> an existing bug in High-Level Api where the messages in the operators are not
> flushed on end of the stream to the next operators. This results in missing
> the messages while testing the Samza code, which makes assertions fail. A
> simple way to reproduce is any writing a Test using Test Framework for High
> Level Api job using Session Window or KeyedTumblingWindows
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
