Hi, >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 ? Thanks.
