Flink AggregateFunction in TumblingWindow is automatically splitted in two windows for big window size – Docker
I'm calculating a simple mean on some records, using different windows sizes. Using 1 hour and 1 week windows there are no problems, and the results are computed correctly. var keyed = src .filter(event -> event.getSensor_id() < 10000) .keyBy(Event::getSensor_id); var…