Re: Event-time and first watermark

2017-09-14 Thread Aljoscha Krettek
ue grows. >> >> I know it's bad for performances, but for the moment it's not the issue, i >> want the most possibly up-to-date watermark. >> >> -Original Message- >> From: Aljoscha Krettek [mailto:aljos...@apache.org] >> Sent: vend

RE: Event-time and first watermark

2017-08-29 Thread Gwenhael Pasquiers
ation ? -Original Message- From: Aljoscha Krettek [mailto:aljos...@apache.org] Sent: mardi 8 août 2017 16:50 To: Gwenhael Pasquiers Cc: Nico Kruber ; user@flink.apache.org Subject: Re: Event-time and first watermark I see. But yes, even in the case the watermark will always be "one behind". Th

Re: Event-time and first watermark

2017-08-08 Thread Aljoscha Krettek
-Original Message- > From: Aljoscha Krettek [mailto:aljos...@apache.org] > Sent: vendredi 4 août 2017 12:22 > To: Gwenhael Pasquiers > Cc: Nico Kruber ; user@flink.apache.org > Subject: Re: Event-time and first watermark > > Hi, > > How are you defining the watermark,

RE: Event-time and first watermark

2017-08-04 Thread Gwenhael Pasquiers
want the most possibly up-to-date watermark. -Original Message- From: Aljoscha Krettek [mailto:aljos...@apache.org] Sent: vendredi 4 août 2017 12:22 To: Gwenhael Pasquiers Cc: Nico Kruber ; user@flink.apache.org Subject: Re: Event-time and first watermark Hi, How are you defining the

Re: Event-time and first watermark

2017-08-04 Thread Aljoscha Krettek
gt; > -Original Message- > From: Nico Kruber [mailto:n...@data-artisans.com] > Sent: jeudi 3 août 2017 16:30 > To: user@flink.apache.org > Cc: Gwenhael Pasquiers > Subject: Re: Event-time and first watermark > > Hi Gwenhael, > "A Watermark(t) declares that

RE: Event-time and first watermark

2017-08-03 Thread Gwenhael Pasquiers
we're misusing the watermark ? B.R. -Original Message- From: Nico Kruber [mailto:n...@data-artisans.com] Sent: jeudi 3 août 2017 16:30 To: user@flink.apache.org Cc: Gwenhael Pasquiers Subject: Re: Event-time and first watermark Hi Gwenhael, "A Watermark(t) declares that event tim

Re: Event-time and first watermark

2017-08-03 Thread Nico Kruber
Hi Gwenhael, "A Watermark(t) declares that event time has reached time t in that stream, meaning that there should be no more elements from the stream with a timestamp t’ <= t (i.e. events with timestamps older or equal to the watermark)." [1] Therefore, they should be behind the actual event wi