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
|
public void testMergingCustomWindows() { |
Imported from Jira BEAM-2945. Original Jira may contain additional context.
Reported by: echauchot.
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
beam/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/WindowTest.java
Line 591 in 001285a
Imported from Jira BEAM-2945. Original Jira may contain additional context.
Reported by: echauchot.