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)
