apache / apache/beam

Tests that UnboundedSources are executed correctly

Open
#18,129 0 comments 0 reactions 0 assignees View on GitHub
bug P3 tests
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
2d 2h
Merged PRs (30d)
205

Description

Specifically, develop a set of RunnableOnService tests that validate runner behavior when executing an Unbounded Source. Validations should include behaviors such as finalizeCheckpoint being called at most once, etc.

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

Contributor guide

Open the contributing guide

Research direction

Start by locating the existing RunnableOnService tests and the runner entry point for executing an Unbounded Source. Trace checkpoint finalization behavior, then add coverage for finalizeCheckpoint being called at most once and the other runner behaviors described in the issue. Done means the test suite validates these unbounded-source execution guarantees.

Written by the indexing model from the issue text.

Assessment

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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.