Re: add() method of AggregateFunction not called even though new watermark is emitted

Hi Do you mean `*windowStream.aggregate`* do not work for all records or just some records. If for some records, can you try to confirm that the assigned watermark is monotonic increase. If for all records, can you confirm that the watermark has reached the end of the window? In another word, cou

[ANNOUNCE] Weekly Community Update 2019/41

Dear community, happy to share a small community update this week with Flink Forward Europe, "Stateful Functions" and a bit more. Flink Development == * [api] Stephan proposes to contribute* Stateful Function (statefun.io )* to Apache Flink. Stateful Functions wer