Re: At what point do watermarks get injected into the stream?

2017-06-12 Thread Fabian Hueske
rallel source? > > > > Ray > > > > *From: *Fabian Hueske <fhue...@gmail.com> > *Date: *Sunday, June 11, 2017 at 5:54 PM > > *To: *Ray Ruvinskiy <ray.ruvins...@arcticwolf.com> > *Cc: *"user@flink.apache.org" <user@flink.apache.org> > *Subje

Re: At what point do watermarks get injected into the stream?

2017-06-12 Thread Ray Ruvinskiy
f.com> Cc: "user@flink.apache.org" <user@flink.apache.org> Subject: Re: At what point do watermarks get injected into the stream? Each parallel instance of a TimestampAssigner independently assigns timestamps. After a shuffle, operators forward the minimum watermark across all inp

Re: At what point do watermarks get injected into the stream?

2017-06-11 Thread Ray Ruvinskiy
that the watermarks are processed in order by the operators receiving them? Thanks, Ray From: Fabian Hueske <fhue...@gmail.com> Date: Saturday, June 10, 2017 at 3:56 PM To: Ray Ruvinskiy <ray.ruvins...@arcticwolf.com> Cc: "user@flink.apache.org" <user@flink.apache.org> Subject: Re: