Jan Lukavský created BEAM-11481:
-----------------------------------
Summary: 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.26.0
Reporter: Jan Lukavský
Assignee: Jan Lukavský
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)