You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Pablo Estrada (Jira)" <ji...@apache.org> on 2020/12/17 22:25:00 UTC

[jira] [Commented] (BEAM-11481) FlinkRunner might not advance output watermark on change of watermark hold

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

Pablo Estrada commented on BEAM-11481:
--------------------------------------

oh I see the PR is in review. Thanks!

> FlinkRunner might not advance output watermark on change of watermark hold
> --------------------------------------------------------------------------
>
>                 Key: BEAM-11481
>                 URL: https://issues.apache.org/jira/browse/BEAM-11481
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>    Affects Versions: 2.25.0, 2.26.0
>            Reporter: Jan Lukavský
>            Assignee: Jan Lukavský
>            Priority: P0
>             Fix For: 2.27.0
>
>          Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> Output watermark of DoFnOperator is advanced only when new input watermark is received. The output watermark might advance even on timer or processed element due to updated watermark hold. This especially holds true in splittable DoFn.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)