Re: When i use the Tumbling Windows, find lost some record

2020-03-26 Thread Dawid Wysakowicz
d On 26/03/2020 08:52, Jim Chen wrote: > Hi, All > >   When i use the Tumbling Windows, find lost some record. My code as > follow > > /env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);/ > /env.addSource(FlinkKafkaConsumer011..) > / > /.a

When i use the Tumbling Windows, find lost some record

2020-03-26 Thread Jim Chen
Hi, All When i use the Tumbling Windows, find lost some record. My code as follow *env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);* *env.addSource(FlinkKafkaConsumer011..)* *.assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor(Time.minutes(3