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)
>
