[ 
https://issues.apache.org/jira/browse/BEAM-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550151#comment-17550151
 ] 

Danny McCormick commented on BEAM-14265:
----------------------------------------

This issue has been migrated to https://github.com/apache/beam/issues/21712

> Flink should hold the watermark at the output timestamp for processing time 
> timers
> ----------------------------------------------------------------------------------
>
>                 Key: BEAM-14265
>                 URL: https://issues.apache.org/jira/browse/BEAM-14265
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>    Affects Versions: 2.39.0
>            Reporter: Steve Niemitz
>            Assignee: Jan Lukavský
>            Priority: P1
>             Fix For: 2.40.0
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Currently the Flink runner doesn't support output timestamps on processing 
> time timers, and instead uses the current output watermark when the timer 
> fires.
> We should update the runner to correctly set a watermark hold at the output 
> timestamp and use it when firing the timer.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to