Apache Flink has deprecated support for Scala. https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support https://cwiki.

Apache Flink has deprecated support for Scala. https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support 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.