apache / apache/beam

Make sure we unit test bounded sessions

Open
#17,999 0 comments 0 reactions 0 assignees View on GitHub
bug core java P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

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.

Imported from Jira [BEAM-279](https://issues.apache.org/jira/browse/BEAM-279). Original Jira may contain additional context.
Reported by: mshields822.

Contributor guide

Open the contributing guide

Research direction

Start by locating the Apache Beam unit tests for Window.into(Sessions...), AfterPane.elementCountAtLeast, and AfterProcessingTime. Add coverage for combinations that should break bounded sessions apart, including repeated messages with the same timestamp, and run the relevant test target to verify those cases.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
stream-processing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.