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.
