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

Flink should hold the watermark at the output timestamp for processing time timers

Details

    • Bug
    • Status: Open
    • P1
    • Resolution: Unresolved
    • 2.39.0
    • 2.40.0
    • runner-flink
    • None

    Description

      Currently the Flink runner doesn't support output timestamps on processing time timers, and instead uses the current output watermark when the timer fires.

      We should update the runner to correctly set a watermark hold at the output timestamp and use it when firing the timer.

      Attachments

        Issue Links

          Activity

            People

              janl Jan Lukavský
              SteveNiemitz Steve Niemitz
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:

                Time Tracking

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