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
