Re: Not able to Assign Watermark in Flink 1.11

Hi Anuj Jain, You need to provide the type parameter when calling WatermarkStrategy.forBoundedOutOfOrderness like this: bookingFlowConsumer.assignTimestampsAndWatermarks(WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofMinutes(15)) Regards, Roman On Fri, Aug 28, 2020 at 6:49 AM aj wrote:

Not able to Assign Watermark in Flink 1.11

I am getting this error when trying to assign watermark in Flink 1.11 *"Cannot resolve method 'withTimestampAssigner(anonymous org.apache.flink.api.common.eventtime.SerializableTimestampAssigner)'"* FlinkKafkaConsumer bookingFlowConsumer = new FlinkKafkaConsumer(topics, new KafkaGenericAvroD