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)

Reply via email to