Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5932 Order of legacy vs new state initialization in the AbstractStreamOperator.
  3. FLINK-5951

Register legacy windowOp timers with timer service in the restoreState().

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • 1.3.0
    • None
    • API / DataStream
    • None

    Description

      Given the addition in https://issues.apache.org/jira/browse/FLINK-5932, now the WindowOperator can register its retrieved legacy timers with the InternalTimerService directly from the restoreState(), and it does not have to keep them in local variables until the open().

      Attachments

        Activity

          People

            kkl0u Kostas Kloudas
            kkl0u Kostas Kloudas
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: