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

Posted to issues@beam.apache.org by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2018/11/23 10:04:00 UTC

[jira] [Closed] (BEAM-6116) Pushed back watermark never emitted in portable Flink runner

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

Maximilian Michels closed BEAM-6116.
------------------------------------
    Resolution: Fixed

Thanks for fixing this and adding a test. Backported to release-2.9.0.

> Pushed back watermark never emitted in portable Flink runner
> ------------------------------------------------------------
>
>                 Key: BEAM-6116
>                 URL: https://issues.apache.org/jira/browse/BEAM-6116
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>    Affects Versions: 2.9.0
>            Reporter: Thomas Weise
>            Assignee: Thomas Weise
>            Priority: Critical
>              Labels: portability-flink
>             Fix For: 2.9.0
>
>          Time Spent: 2h 10m
>  Remaining Estimate: 0h
>
> The portable runner pushes back the watermark while the bundle processes in the SDK worker. After the bundle is complete, that watermark needs to be emitted. That never happens, because ExecutableStageDoFnOperator does not clear the hold.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)