下载


Apache Flink® 1.8.0 是我们最新的稳定版本。

如果你计划将 Apache Flink 与 Apache Hadoop 一起使用(在 YARN 上运行 Flink ,连接到 HDFS ,连接到 HBase ,或使用一些基于 Hadoop 文件系统的 connector ),请选择包含匹配的 Hadoop 版本的下载包,且另外下載对应版本的 Hadoop 库,并且把下载后的 Hadoop 库放置 到 Flink 安装目录下的 lib 目录 包并设置 HADOOP_CLASSPATH 环境变量

Apache Flink 1.8.0 for Scala 2.11 (asc, sha512)

Apache Flink 1.8.0 for Scala 2.12 (asc, sha512)

Apache Flink 1.8.0 Source Release (asc, sha512)

可选组件

Avro SQL Format (asc, sha1)

CSV SQL Format (asc, sha1)

JSON SQL Format (asc, sha1)

Pre-bundled Hadoop 2.4.1 (asc, sha1)

Pre-bundled Hadoop 2.6.5 (asc, sha1)

Pre-bundled Hadoop 2.7.5 (asc, sha1)

Pre-bundled Hadoop 2.8.3 (asc, sha1)

发布说明

如果你计划从以前的版本升级 Flink,请查看 Flink 1.8 的发布说明

Apache Flink 1.7.2 for Scala 2.11 (asc, sha512)

Apache Flink 1.7.2 for Scala 2.12 (asc, sha512)

Apache Flink 1.7.2 Source Release (asc, sha512)

可选组件

Avro SQL Format (asc, sha1)

JSON SQL Format (asc, sha1)

其他替代执行包

Apache Flink 1.7.2 with Hadoop® 2.4 for Scala 2.11 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.4 for Scala 2.12 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.6 for Scala 2.11 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.6 for Scala 2.12 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.7 for Scala 2.11 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.7 for Scala 2.12 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.8 for Scala 2.11 (asc, sha512)

Apache Flink 1.7.2 with Hadoop® 2.8 for Scala 2.12 (asc, sha512)

发布说明

如果你计划从以前的版本升级 Flink,请查看 Flink 1.8 的发布说明

Apache Flink 1.6.4 for Scala 2.11 (asc, sha512)

Apache Flink 1.6.4 Source Release (asc, sha512)

其他替代执行包

Flink 1.6.4 with Hadoop® 2.4 for Scala 2.11 (asc, sha512)

Flink 1.6.4 with Hadoop® 2.6 for Scala 2.11 (asc, sha512)

Flink 1.6.4 with Hadoop® 2.7 for Scala 2.11 (asc, sha512)

Flink 1.6.4 with Hadoop® 2.8 for Scala 2.11 (asc, sha512)

发布说明

如果你计划从以前的版本升级 Flink,请查看 Flink 1.8 的发布说明

额外组件

其他不包含在 Flink 的主要发布的组件如下所示:

Apache Flink-shaded 6.0 (asc, sha512)

验证哈希和签名

随着每次版本发布,我们还提供了包含 sha512 哈希的 *.sha512 文件和包含加密签名的 *.asc 文件。Apache 软件基金会有一个通用的教程来验证哈希和签名,你可以使用这些版本签名的 KEYS 来校验它们。

Maven 依赖

你只要将以下依赖项添加到 pom.xml 中,就能在项目中引入 Apache Flink 。这些依赖项包含了本地执行环境,因此支持本地测试。

  • Scala API: 为了使用 Scala API,将 flink-java 的 artifact id 替换为 flink-scala_2.11,同时将 flink-streaming-java_2.11 替换为 flink-streaming-scala_2.11
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.8.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.8.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.8.0</version>
</dependency>

旧版本的更新策略

截至2017年3月,Flink 社区决定使用 bugfix 来支持当前和之前的次要版本。如果 1.2.x 是当前的正式版本,则 1.1.y 是之前的次要支持版本。这两个版本都将收到关键问题的 bugfix。

请注意,社区始终愿意讨论旧版本的 bugfix 版本。请在 dev@flink.apache.org 邮件列表中与开发人员联系。

所有稳定版本

所有的 Flink 版本均可通过 https://archive.apache.org/dist/flink/ 获得,包括校验和加密签名。在撰写本文时,这包括以下版本:

  • Flink-shaded 6.0 - 2019-02-12 (Source)
  • Flink-shaded 5.0 - 2018-10-15 (Source)
  • Flink-shaded 4.0 - 2018-06-06 (Source)
  • Flink-shaded 3.0 - 2018-02-28 (Source)
  • Flink-shaded 2.0 - 2017-10-30 (Source)
  • Flink-shaded 1.0 - 2017-07-27 (Source)