Hi, KeyBy operation partition the data on given key and make sure same slot will get all future data belonging to same key. In default implementation, it can also map subset of keys in your DataStream to same slot.
Assuming you have number of keys equal to number running slot then you may specify your custom keyBy operation to the achieve the same. Could you specify your case. -- Thanks Amit -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
