flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gwenhael Pasquiers <gwenhael.pasqui...@ericsson.com>
Subject Event-time and first watermark
Date Thu, 03 Aug 2017 08:24:35 GMT

>From my tests it seems that the initial watermark value is Long.MIN_VALUE even though
my first data passed through the timestamp extractor before arriving into my ProcessFunction.
It looks like the watermark "lags" behind the data by one message.

Is there a way to have a watermark more "up to date" ? Or is the only way to compute it myself
into my ProcessFunction ?


View raw message