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