Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4651

Re-register processing time timers at the WindowOperator upon recovery.

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      Currently the WindowOperator checkpoints the processing time timers, but upon recovery it does not re-registers them with the TimeServiceProvider. To actually reprocess them it relies on another element that will come and register a new timer for a future point in time. Although this is a realistic assumption in long running jobs, we can remove this assumption by re-registering the restored timers with the TimeServiceProvider in the open() method of the WindowOperator.

        Attachments

          Activity
          $i18n.getText('security.level.explanation', $currentSelection) Viewable by All Users
          Cancel

            People

            • Assignee:
              kkl0u Kostas Kloudas
              Reporter:
              kkl0u Kostas Kloudas

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment