Flink AggregateFunction Help

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink AggregateFunction Help

Alexx
Hello!

I'm unable to see any results from .print() after performing an AggregateFunction over a timeWindow.

I made a very detailed post on StackOverflow:

Thank you!
Reply | Threaded
Open this post in threaded view
|

Re: Flink AggregateFunction Help

Alexx
Fixed. Issue with Timestamp. That is why the windowing function wasnt working properly.