Hello everyone 🙂 , I am learning about the Flink and was reading some resources from the official webpage. I think latest example provided in this page does not make sense in terms of using the API for the wanted result. Initially it states that: In this example, a control stream is used to specify words which must be filtered out of the

streamOfWords

. A

RichCoFlatMapFunction

called

ControlFunction

is applied to the connected streams to get this done. Then it says: It is important to recognize that you have no control over the order in which the

flatMap1

and

flatMap2

callbacks are called So if flatmap2 is called before flatmap1 then we do not filter specified words. Do I think/structure this correctly? If so, where should I reach to kindly ask for this example to be changed to something else?