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
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
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: