I need to do event-time based aggregation on data from MapR-Streams and have found that Spark is not capable of doing this without structured streaming (alpha in 2.1.0).
So, I'd like to use Flink. Is there a Flink/YARN example application available anywhere?
I see numerous MapR answers about Flink + YARN which make it look... frustrating? to get working and if a clear example exists I'd much prefer to start there!