Hi! I have been searching a lot but I didn't found a solution for this.
Lets supose some of the steps on the streaming process must be executed in just a subset of the available nodes/taskmanagers, while the rest of the tasks are free to be computed anywhere. **¿How can I assign a DataStream to be executed ONLY in a node subset?** This is required mainly for input/sink tasks as not every node in the cluster have the same conectivity / security restrictions. I'm new on flink, so please forgive me if I'm asking for something obvious. Thanks a lot. Rafael Leira. Pd: Currently, we have a static standalone flink cluster.
