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

Reply via email to