holdenk / holdenk/spark-testing-base
Run Streaming Tests Distributively
Open
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 357
- PR merge metrics
- No merged PRs in 30d
Description
Currently we are only supporting input and output as Lists. We need to add support to General InputStreams and run the tests distributively.
Contributor guide
Research direction
No files, tests, or entry points are named in the issue. Start by locating the streaming test code and its List-based input and output handling, then determine how distributive execution is represented; done means General InputStreams are supported and the streaming tests run distributively.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- scala
- Domain
- distributed-systems, testing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100