Thanks Yun.
I have converted the code to use a keyed-processed function rather than a
flatMap and using register timer it worked.
On Fri, May 29, 2020 at 11:13 AM Yun Gao wrote:
> Hi,
>
> I think you could use *timer* to achieve that. In *processFunction*
> you could register a timer at sp
Hi,
I think you could use timer to achieve that. In processFunction you could
register a timer at specific time (event time or processing time) and get
callbacked at that point. It could be registered like
ctx.timerService().registerEventTimeTimer(current.lastModified + 6);
More det
