[ 
https://issues.apache.org/jira/browse/BEAM-12690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Beam JIRA Bot updated BEAM-12690:
---------------------------------
    Labels: stale-assigned  (was: )

> GroupIntoBatches does not properly maintain watermarks
> ------------------------------------------------------
>
>                 Key: BEAM-12690
>                 URL: https://issues.apache.org/jira/browse/BEAM-12690
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-core
>            Reporter: Reuven Lax
>            Assignee: Reuven Lax
>            Priority: P3
>              Labels: stale-assigned
>             Fix For: 2.34.0
>
>          Time Spent: 2h 10m
>  Remaining Estimate: 0h
>
> 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.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to