You configure the ExecutionConfig#setAutoWatermarkInterval on the StreamExecutionEnvironment by calling getConfig().
Cheers, Till On Tue, Sep 25, 2018 at 11:54 PM Chang Liu <fluency...@gmail.com> wrote: > 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 > > >
