[BEAM-12690] GroupIntoBatches does not properly maintain watermarks

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Fix Version/s: 2.34.0
• Component/s: sdk-java-core
• Assignee: Unassigned
• Reporter: Reuven Lax
• Created: 29/Jul/21 21:24
• Updated: 04/Jun/22 21:02

Description

Since GIB buffers elements, the watermark should be held up to the minimum event-time buffered. Timer.withOutputTimestamp is the correct way to do this in Beam.

Issue Links

• links to: GitHub Pull Request #15249