Hi,
The KeyedBroadcastProcessFunction#processBroadcastElement is called in
outer CoBroadcastWithKeyedOperator[1], CoBroadcastWithKeyedOperator is a
two-input operator. As David says, this operator is run in a single thread,
so the processBroadcastElement
method will run to completion before any fu
In Flink, all user functions, including KeyedBroadcastProcessFunction,
are (effectively) single threaded, so the processBroadcastElement
method will run to completion before any further messages are
processed in the processElement method. (I said "effectively" because
in the case of processing time
