flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From madhairsilence <harish.kum...@tcs.com>
Subject Sliding Window - Weird behaviour
Date Thu, 13 Apr 2017 08:43:13 GMT
I have a datastream
1,2,3,4,5,6,7....

I applied a sliding countWindow as
inputStream.keyBy("num").countWindow(2,1)

I expect an output as
1,2
2,3
3,4

But am getting an output as
1
1,2
2,3
3,4

Why does the data slide first and then accumulate the window size



--
View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Sliding-Window-Weird-behaviour-tp17013.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message