Re: WindowOperator initial watermark

2016-04-15 Thread Aljoscha Krettek
Yes, you are right, that's a bit inconsistent. I'll push a commit to fix it. On Thu, 14 Apr 2016 at 23:45 Michael Radford wrote: > This is a really minor issue, but it confused me during testing. > > The WindowOperator initial watermark is -1: > > > https://github.

WindowOperator initial watermark

2016-04-14 Thread Michael Radford
This is a really minor issue, but it confused me during testing. The WindowOperator initial watermark is -1: https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java#L136 Whereas