Hi Eugenio,
I think it is due to window completion which will be complete once your
watermarked field on the event advances 15 days interval since the first
received event time.
Please also check this default trigger behavior here:
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/de
Hi everyone,
I’m trying to calculate an average with a sliding window. Here’s the code I’m
using. First of all I receive a series of events from a Kafka topic. I declared
a watermark on the ‘data_fine’ attribute.
final TableDescriptor filteredPhasesDurationsTableDescriptor =
TableDescriptor.fo
