HI Soheil,
That may relate to your parallelism since each extractor instance compute its
own watermarks. Try to print the max timestamps with the current thread’s name
and you will notice this.
Best,
Xingcan
> On Jul 30, 2018, at 3:05 PM, Soheil Pourbafrani wrote:
>
> Using Flink EventTime
Using Flink EventTime feature, I implement the class
AssignerWithPeriodicWatermark such that:
public static class SampleTimestampExtractor implements
AssignerWithPeriodicWatermarks> {
private static final long serialVersionUID = 1L;
private long MAX_TIMESTAMP;
private final long DELEY
