Skip to content

GroupIntoBatches does not properly maintain watermarks #21071

@damccorm

Description

@damccorm

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.

Imported from Jira BEAM-12690. Original Jira may contain additional context.
Reported by: reuvenlax.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions