This is not exposed programatically. Depending on which runner your using,
you may be able to query for the watermark through its monitoring APIs if
it is exposed as a metric and you know what it is called. This is likely to
be brittle implementation and also the data is likely to be stale.

On Thu, May 17, 2018 at 1:31 AM Jozef Vilcek <> wrote:

> Hello,
> is there a way to observe `current watermark` when processing elements of
> triggered window?
> What I am trying to achieve is, to have on one window quite large late
> comer event allowance and I want to log information on how much late behind
> the watermark event did came in.

Reply via email to