Hello Tony, Thanks a lot for your answer. Now I know exactly what happens with keyBy function, yet still I haven't figured out a proper (non hard coded way) to deterministically send a tuple to each key.
If somenone from the Flink team could help it would be great! Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/