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
