Hi Till,

You mean use AssignerWithPeriodicWatermarks but combine the logic of Event time 
and Processing Time (or to say depend on the time difference/interval of 
Processing time, but the Watermark value is still depending on the Event time 
right)?

One additional question: where do I config this: 
ExecutionConfig.setAutoWatermarkInterval(…) ?

Many thanks :)

Best regards/祝好,

Chang Liu 刘畅


> On 25 Sep 2018, at 23:41, Till Rohrmann <trohrm...@apache.org> wrote:
> 
> AssignerWithPeriodicWatermarks

Reply via email to