Re: Flink join operator after sorting seems to group fields (Scala)

Hi Felipe, the `sortPartition()` method just LOCALLY sorts each partition of a dataset. To achieve a global sorting, use this method after a `partitionByRange()` (e.g., `result.partitionByRange(0).sortPartition(0, Order.ASCENDING)`). Hope that helps, Xingcan > On 3 Mar 2018, at 9:33 PM, Felipe

Flink join operator after sorting seems to group fields (Scala)

Hi all, I have implemented a simple Scala object using Flink to play with joins operator. After that, I put the join operator show my results I decided to sort the output by the first field (.sortPartition(0, Order.ASCENDING)). It seems that the output is ordered by group. The output shows two gro