Nexmark: Fix query9 window merging
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 2d 2h
- Merged PRs (30d)
- 205
Description
Nexmark Query9 uses custom windows and merges them. It runs fine in spark runner even if spark runner does not support custom window merging yet (https://issues.apache.org/jira/browse/BEAM-2499). So fix the merge process in Query9 to be closer to https://github.com/apache/beam/blob/001285a88c9e12473ea31241146208a4b61fb0ef/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/WindowTest.java#L591
Imported from Jira [BEAM-2945](https://issues.apache.org/jira/browse/BEAM-2945). Original Jira may contain additional context.
Reported by: echauchot.
Contributor guide
Research direction
Use the linked WindowTest.java section as the behavioral reference, then locate Nexmark Query9's custom-window merge code. Done means Query9's merge process follows that reference and continues to run correctly in the Spark runner.
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
- Needs clarification
- Newbie friendliness
- 35/100