Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4747 Instability due to pending processing timers on operator close
  3. FLINK-4750

Ensure that active processing time triggers complete before closing operators

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.2.0
    • 1.2.0
    • None
    • None

    Description

      To avoid that processing time triggers access closed/disposed operators, active triggers should be waited for when closing the operators.

      This is only relevant for operations on finite streams.

      Attachments

        Activity

          People

            sewen Stephan Ewen
            sewen Stephan Ewen
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: