Hi, if you think this is a good feature, what about put it into jira[1] and
start a discussion in dev-mail? Someone familiar with the relevant modules will
discuss with you.<br/>[1] https://issues.apache.org/jira/projects/FLINK/issues
At 2022-07-07 17:43:03, "James Sandys-Lumsdaine" <jas...@hotmail.com> wrote:
>Hello,
>
>I know we can’t set a timer in the processBroadcastElement() of the
>KeyedBroadcastProcessFunction as there is no key.
>
>However, there is a context.applyToKeyedState() method which allows us to
>iterate over the keyed state in the scope of a key. So it is possible to add
>access to the TimerService onto the Context parameter passed into that
>delegate?
>
>Since the code running in the applyToKeyedState() method is scoped to a key we
>should be able to set up timers for that key too.
>
>Thanks,
>
>James.
