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

Posted to issues@beam.apache.org by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/11/22 17:44:00 UTC

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

Thomas Weise created BEAM-6116:
----------------------------------

             Summary: 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
             Fix For: 2.9.0


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)