Hey guys. Lets say i have a cluster setup with 5 machines. I am wondering how to distribute an operator (e.g. MapPartition) to all machines, exactly one per machine. All of them should read a specific source completely.
As i see flink broadcast variable do not work because i nee two different sources. Is there an other way? Kay
