Apache Flink has deprecated support for Scala.

https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+D...

An aggregation engine like that was otherwise a good fit for a functional-ish language like Scala.

That said - it is a nice language. Native support for simple functional language constructs (map / flatmap, Option, Try), without having to go all-in on functional style.