flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael Radford <mub...@gmail.com>
Subject WindowOperator initial watermark
Date Thu, 14 Apr 2016 21:45:39 GMT
This is a really minor issue, but it confused me during testing.

The WindowOperator initial watermark is -1:


Whereas TimestampsAndPunctuatedWatermarksOperator uses Long.MIN_VALUE:


I happened to be testing with time values near 0 (including negative
ones) so that it was easier to see what window a timestamp belonged
in, and it was mysterious at first where the -1 watermark was coming
from, when my code was starting with watermarks below that.

I doubt many users are processing data from 1969 with Flink, but
perhaps it's better to use Long.MIN_VALUE everywhere?


View raw message