It would be good if you could elaborate a bit more on your use-case.
Are you using batch or streaming? What kind of "message" are we talking about? Why are you thinking of using a static variable, instead of just treating this message as part of the data(set/stream)?

On 11/5/2020 12:55 PM, Si-li Liu wrote:
Currently I use Flink 1.9.1. The actual thing I want to do is send some messages from downstream operators to upstream operators, which I consider use static variable.

But it makes me have to make sure in one taskmanager process it always has these two operators, can I use CoLocationGroup to solve this problem? Or can anyone give me an example to demostrate the usage of CoLocationGroup ?

Thanks!
--
Best regards

Sili Liu


Reply via email to