Hi to all, I'm trying to exploit async IO in my Flink job. In my use case I use keyed tumbling windows and I'd like to execute the async action only once per key and window (while the AsyncDataStream.unorderedWait execute the async call for every element of my stream) ..is there an easy way to do that apart from using a process function (that basically will lose the asynchronicity)?
Best, Flavio