Do you mean that window results with timestamps larger than the 6th hour won't be output? Can it be the case that some of the keys simply don't have elements arriving after the 6th hour? It's really hard to tell given no knowledge about your input data set. Maybe you can compile a small example code and data set to reproduce your problem. This would help me to debug the issue.
Cheers, Till On Mon, Mar 27, 2017 at 11:51 AM, Sonex <alfredjens...@gmail.com> wrote: > The degree of parallelism in the experiments I mentioned is 8. If I > decrease > the parallelism it emits more results. If I set the parallelism to 1 then > it > emits results from the entire dataset (i.e., it behaves as expected). What > could be the reason of this? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Windows-emit- > results-at-the-end-of-the-stream-tp12337p12410.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
