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

ExecutableStageDoFnOperator should fire processing time timers properly instead of draining it directly when close() happens

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-flink
    • None

    Description

      We hit this case when processing time timer holds the watermark but at the same time we are closing the operator.

      One typical case is when SDF sets timer for rescheduling residuals.

      Attachments

        Activity

          People

            Unassigned Unassigned
            boyuanz Boyuan Zhang
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: