Tests that UnboundedSources are executed correctly
- 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
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