Hey Yun, I wonder whether we need to add a new option when registering timers. Won't it be sufficient to flush all pending timers on termination but not allow new ones to be registered?
-Max On Wed, Nov 2, 2022 at 11:20 AM Yun Gao <yungao...@aliyun.com.invalid> wrote: > 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 > >
