Search code examples
scalaapache-flink

What version of Scala does Apache Flink use?


I'm getting started with Apache Flink. I noticed on the Apache Flink download page, it says "Apache Flink 1.14.3 for Scala 2.11 (asc, sha512)" as the name of the installation file.

Can you confirm there is no Apache Flink for Scala 3.x? I want to make sure I download the right version of Scala


Solution

  • Flink up to 1.14 is available in both a Scala 2.11 and Scala 2.12 binary, which can be downloaded from https://flink.apache.org/downloads.html. This means that you can use Flink's Scala API with either Scala 2.11 or Scala 2.12.

    In Flink 1.15 (the next version), support for Scala 2.11 is dropped. Next to that, all Java APIs are independent from Scala. You can find more information at https://issues.apache.org/jira/browse/FLINK-23986

    This means that if you would like to use Scala 3.0 in combination with Flink 1.15, that's possible. You can find some examples at https://github.com/sjwiesman/flink-scala-3