Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3643 Improve Windowing
  3. FLINK-4239

Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.1.0
    • Fix Version/s: 1.1.0
    • Component/s: API / DataStream
    • Labels:
      None

      Description

      In preparation for upcoming changes in 1.2 we should set the default allowed lateness to zero and make all built-in triggers non-purging by default.

      Currently, EventTimeTrigger and ProcessingTimeTrigger purge when they fire. This leads to unexpected behavior when a user sets some meaningful allowed lateness. The behavior will be that the window is purged when firing and the state will not actually be kept within the allowed lateness.

      Changing the behavior to non-purging requires changing the default allowed lateness from Long.MAX_VALUE to 0. Otherwise we would have memory leaks.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                aljoscha Aljoscha Krettek
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: