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