Re: [DataStream API] Watermarks not closing TumblingEventTimeWindow with Reduce function

2022-04-29 Thread r pp
ly to use #aggregate but it should be fixed >> nonetheless. >> >> On Fri, Apr 1, 2022 at 9:58 AM r pp wrote: >> >>> hi~ Can you send your full code ？ >>> >>> Ryan van Huuksloot 于2022年3月31日周四 >>> 22:58写道： >>>

Re: [DataStream API] Watermarks not closing TumblingEventTimeWindow with Reduce function

2022-04-01 Thread r pp
hi~ Can you send your full code ？ Ryan van Huuksloot 于2022年3月31日周四 22:58写道： > Hello! > > *Problem:* > I am connecting to a Kafka Source with the Watermark Strategy below. > > val watermarkStrategy = WatermarkStrategy > .forBoundedOutOfOrderness(Duration.of(2, ChronoUnit.HOURS)) > .withTimest