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

Posted to commits@samza.apache.org by "Sanil Jain (Jira)" <ji...@apache.org> on 2019/10/24 18:31:00 UTC

[jira] [Updated] (SAMZA-2057) Window operator on encountering end of stream does not emit the last window pane

     [ https://issues.apache.org/jira/browse/SAMZA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sanil Jain updated SAMZA-2057:
------------------------------
    Description: 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

> 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)