Hi everyone,
I would like to open a discussion[1] on how to
properly handle the processing timers on job
termination.
Currently all the processing timers would be
ignored on job termination. This behavior is
not suitable for some cases like WindowOperator.
Thus we'd like to provide more options for how
to deal with the pending times on job termination,
and provide correct semantics on bounded stream
for these scenarios. The FLIP is based on the previous
discussion with Piotr and Divye in [2].
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-269%3A+Properly+Handling+the+Processing+Timers+on+Job+Termination
<https://cwiki.apache.org/confluence/display/FLINK/FLIP-269%3A+Properly+Handling+the+Processing+Timers+on+Job+Termination
>
[2] https://issues.apache.org/jira/browse/FLINK-18647
<https://issues.apache.org/jira/browse/FLINK-18647 >
