Hi, If you use `partitionCustom()` method [1] with custom partitioner, you can guarantee the order of partition.
Regards, Chiwan Park [1] https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/api/java/DataSet.html#partitionCustom(org.apache.flink.api.common.functions.Partitioner,%20int) > On Jul 15, 2015, at 1:10 AM, Juan Fumero > <juan.jose.fumero.alfo...@oracle.com> wrote: > > Hi, > I am doing pure map computation with typical benchmarks like > BlackScholes and NBody. > > I am using local configuration with multiple threads. It seems like, > inside the chuck (total size / numThreads) the order is correct. But the > ordering between chunks is not correct, giving an incorrect result at > the end. > > What I mean by the order is, the correct result in the correct position > of the array. > > Is there any way to guarantee the result? > > Many thanks > Juan >
