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)
