Hi, I am new to flink. I am trying to write a job that updates the Keyed State when a Broadcast Message is received in KeyedBroadcastProcessFunction. I was wondering will the *ctx.applyToKeyedState* in the processBroadCastElement will get completed before further messages are processed in the *processElement* function? Can someone explain or point me to some docs on how the synchronisation of Broadcasted and non Broadcasted messages works in KeyedBroadcastProcessFunction?
Kind regards Anil
