Hi all, Not sure if it’s a typical use case but is it a good idea to synchronize the processElement and onTimer methods of a KeyedProcessFunction?
In my case they both do changes in the function’s state (processElement initiates the state if not initialized and onTime clears the state) and I would not like to create race conditions. Does Flink call onTimer in a synchronized with processElement manner? Will using the synchronized modifier have a bad impact on the performance? Cheers, Vadim
