Hey Fabian! Thanks for the comprehensive replies. Now I understand those concepts properly.
Regarding .rescale() , it does not receive any arguments. Thus, I assume that the way it does the shuffling from operator A to operator B instances is a black box for the programmer and probably has to do with the number of slots in each taskmanager. It strives to favour local data exchange (aka *intra-exchange* : between slot of the same taskmanager) instead of *inter-exchange* of data between different taskmanagers (that burdens the network). Am I correct? Thanks in advance. Best, Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
