[jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

["Kostas Kloudas (JIRA)" <ji...@apache.org>]

Kostas Kloudas created FLINK-4651:
-------------------------------------

             Summary: Re-register processing time timers at the WindowOperator upon recovery.
                 Key: FLINK-4651
                 URL: https://issues.apache.org/jira/browse/FLINK-4651
             Project: Flink
          Issue Type: Bug
          Components: Windowing Operators
            Reporter: Kostas Kloudas
            Assignee: Kostas Kloudas
             Fix For: 1.1.3


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}}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)