Hi Pablo Flores,
I think there is a missing method `trigger()` taking an async trigger for
WindowedStream. Will add this[1].
And we also should add a converter from `ProcessingTimeoutTrigger` with any
nested timer to the async version, like others do[2]. A ticket is tracking
this[3].
But currentl
Thanks for the quick response and for clarifying this, I was stuck for a
couple hours and found no other way than modifying the flink distribution.
Knowing this makes the time spent worth it.
I'll keep an eye on the progress of this, or if I have a chance I'll share
some of the changes that worked
Hello,
I'm trying to find a way to read a stream of events from Kafka, key
them with a proper key function and then grouping records in windows
of a given size with the Count trigger or to buffer the window for a
couple seconds. Since the system could receive multiple GBs of data in
a very short pe
