Apache Flink 使用什么版本的 Scala?

What version of Scala does Apache Flink use?

我正在开始使用 Apache Flink。我注意到在 Apache Flink 下载页面上,安装文件的名称为“Apache Flink 1.14.3 for Scala 2.11 (asc, sha512)”。

您能否确认没有 Apache Flink for Scala 3.x?我想确保我下载了正确版本的 Scala

Scala 2.11 和 Scala 2.12 二进制文件中都提供了最高 1.14 的 Flink,可以从 https://flink.apache.org/downloads.html 下载。这意味着您可以将 Flink 的 Scala API 与 Scala 2.11 或 Scala 2.12 一起使用。

在 Flink 1.15(下一个版本)中,不再支持 Scala 2.11。除此之外,所有 Java API 都独立于 Scala。您可以在 https://issues.apache.org/jira/browse/FLINK-23986

找到更多信息

这意味着如果你想将 Scala 3.0 与 Flink 1.15 结合使用,这是可能的。您可以在 https://github.com/sjwiesman/flink-scala-3

找到一些示例