Программа сделала уменьшение, но не полностью, потому что ваш ввод должен был попасть в два разных 5-секундных окна.Вот почему 4 экземпляра ipsum, о которых сообщается как 1 + 3 - первый попал в одно окно, а остальные 3 - в другое окно (вместе с «пока»).
Границы окна Флинка основаныпо согласованию с часами.Так, если ваши входные события произошли, например, между 14:00:04 и 14:00:08, они попали бы в два 5-секундных окна - одно для 14:00:00 - 14: 00: 04.999 и другое для 14:00:05 - 14: 00: 09.999 - даже если все ваши события укладываются в один интервал, который длится всего 4 секунды.
Если вы попытаетесь снова, вы можете ожидать увидеть похожие, но, вероятно, разные результаты,Это является следствием выполнения оконной аналитики, основанной на «времени обработки».Если вы хотите, чтобы ваши приложения получали повторяемые результаты, вы должны вместо этого планировать использовать аналитику " event time " (где отметки времени основаны на том, когда события произошли, а не когда они были обработаны).