Exactly, I have more than 4 keys because the "nenative modulo", after thange this line from
*.keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism)* to *.keyBy(mappedPayload => Math.abs(mappedPayload._1.id.hashcode % parallelism))* *or just profit Flink's dataStream.partitionByHash(Field)* *Thanks for your help! Cheers :)* 2016-02-03 14:35 GMT+01:00 Aljoscha Krettek <aljos...@apache.org>: > How long did you run the job? Could it be an artifact of the timing and it > hasn’t yet averaged out. > > On 03 Feb 2016, at 14:32, Aljoscha Krettek <aljos...@apache.org> wrote: > > > > There should be 4 windows because there are only 4 distinct keys, if I > understand this line correctly: > > > > .keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism) > > > >> On 02 Feb 2016, at 19:31, yutao sun <yutao.sun...@gmail.com> wrote: > >> > >> .keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism) > > > >
