Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-11481

FlinkRunner might not advance output watermark on change of watermark hold

Details

    • Bug
    • Status: Resolved
    • P0
    • Resolution: Fixed
    • 2.25.0, 2.26.0
    • 2.27.0
    • runner-flink
    • None

    Description

      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.

      Attachments

        Activity

          People

            janl Jan Lukavský
            janl Jan Lukavský
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 4h 50m
                4h 50m