Hi everybody,
I launched a topology applying a tumbling count window of size 2 (watermark
interval 200ms, lag 1s) with the following input:
70
60
20 50
10 30 40 80 90 100 values
|———|———|———|———|———|—————> time
10 11 12 13 14 15
timestamps [s]
And I got these windows as output (the format for a tuple is (timestamp,
value)):
[(10,10), (10,20)]
[(12,60), (12,70)]
[(12,60), (12,70)] // why (60, 70) 2 times?
[(13,80), (14,90)]
I would expect something like:
[(10,10), (10,20)]
[(11,30), (12,40)]
[(12,50), (12,60)]
[(12,70), (13,80)]
[(14,90), (15,100)]
Can anyone explain to me this behavior?
Thank you in advance.
Lorenzo Affetti
