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

Posted to commits@beam.apache.org by "Mark Shields (JIRA)" <ji...@apache.org> on 2016/05/12 19:58:13 UTC

[jira] [Created] (BEAM-279) Make sure we unit test bounded sessions

Mark Shields created BEAM-279:
---------------------------------

             Summary: Make sure we unit test bounded sessions
                 Key: BEAM-279
                 URL: https://issues.apache.org/jira/browse/BEAM-279
             Project: Beam
          Issue Type: Bug
            Reporter: Mark Shields


A few customers have been using Window.into(Sessions...) and of course quickly realize they are exposed to unbounded sessions.

We should have unit tests to confirm various combinations of AfterPane.elementCountAtLeast and AfterProcessingTime... correctly force sessions to be broken apart.

We should also check this all works with repeated messages with the same timestamp (since they will create the exact same session window and can thus see trigger state from previous sessions).

At some point we may may flow into reworking bounded sessions to be done directly rather than via Sessions plus triggers.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)