Hi Averell, The keyBy transformation will trigger the key partition, which is one of the various partition types supported by Flink, which causes the data to be shuffled. It routes the keys of the same hash value to the same node based on the hash of the key you passed (or generated by the custom partitioner).
Thanks, vino. 2018-07-31 9:33 GMT+08:00 Averell <[email protected]>: > Oh, Thank you Vino. I was not aware of that reshuffling after every custom > partitioning. Why would that needed though? > > Thanks and regards, > Averell > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
