Hi, Records with the same key will be processed by the same partition. Note there isn't an instance of a keyed process function for each key. There is a single instance per partition, and all keys that are distributed to the same partition will get processed by the same keyed process function instance.
Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
