Apache Flink® Downloads #

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

Apache Flink 1.19.0 (asc, sha512)

Apache Flink 1.19.0 Source Release (asc, sha512)

Release Notes #

Please have a look at the Release Notes for Apache Flink 1.19.0 if you plan to upgrade your Flink setup from a previous version.

Apache Flink 1.18.1 (asc, sha512)

Apache Flink 1.18.1 Source Release (asc, sha512)

Release Notes #

Please have a look at the Release Notes for Apache Flink 1.18.1 if you plan to upgrade your Flink setup from a previous version.

Apache Flink 1.17.2 (asc, sha512)

Apache Flink 1.17.2 Source Release (asc, sha512)

Release Notes #

Please have a look at the Release Notes for Apache Flink 1.17.2 if you plan to upgrade your Flink setup from a previous version.

Apache Flink 1.16.3 (asc, sha512)

Apache Flink 1.16.3 Source Release (asc, sha512)

Release Notes #

Please have a look at the Release Notes for Apache Flink 1.16.3 if you plan to upgrade your Flink setup from a previous version.

These are connectors that are released separately from the main Flink releases.

Apache Flink AWS Connectors 4.2.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink Cassandra Connector 3.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

  • 1.17.x

Apache Flink Elasticsearch Connector 3.0.1 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

  • 1.17.x

Apache Flink Google Cloud PubSub Connector 3.0.2 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink HBase Connector 3.0.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

  • 1.17.x

Apache Flink JDBC Connector 3.1.2 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

  • 1.17.x

  • 1.18.x

Apache Flink Kafka Connector 3.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink MongoDB Connector 1.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink Opensearch Connector 1.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink Pulsar Connector 3.0.1 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

Apache Flink Pulsar Connector 4.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.x

  • 1.18.x

Apache Flink RabbitMQ Connector 3.0.1 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

  • 1.17.x

Apache Flink® Stateful Functions 3.3 是我们最新的稳定版本。

Apache Flink Stateful Functions 3.3.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.2

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

Apache Flink ML 2.3.0 Source Release (asc, sha512)

Apache Flink ML 2.3.0 Python Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.17.*

Apache Flink ML 2.2.0 Source Release (asc, sha512)

Apache Flink ML 2.2.0 Python Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.15.*

Apache Flink® Kubernetes Operator 1.8 是我们最新的稳定版本。

Apache Flink Kubernetes Operator 1.8.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.18.x

  • 1.17.x

  • 1.16.x

  • 1.15.x

Apache Flink Kubernetes Operator 1.7.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.18.x

  • 1.17.x

  • 1.16.x

  • 1.15.x

Apache Flink® Table Store 0.3 是其作为Flink子项目时,最后的发布版本。目前其已经成为Apache Paimon(incubating)项目。

Apache Flink Table Store 0.3.0 (asc, sha512)

Apache Flink Table Store 0.3.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.16.x

Apache Flink Table Store 0.2.1 (asc, sha512)

Apache Flink Table Store 0.2.1 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.15.x

Apache Flink Table Store 0.1.0 (asc, sha512)

Apache Flink Table Store 0.1.0 Source Release (asc, sha512)

This component is compatible with Apache Flink version(s):

  • 1.15.x

额外组件 #

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

Pre-bundled Hadoop 2.8.3 #

Pre-bundled Hadoop 2.8.3 Source Release (asc, sha512)

Pre-bundled Hadoop 2.7.5 #

Pre-bundled Hadoop 2.7.5 Source Release (asc, sha512)

Pre-bundled Hadoop 2.6.5 #

Pre-bundled Hadoop 2.6.5 Source Release (asc, sha512)

Pre-bundled Hadoop 2.4.1 #

Pre-bundled Hadoop 2.4.1 Source Release (asc, sha512)

Apache Flink-shaded 18.0 Source Release Source Release (asc, sha512)

Apache Flink-shaded 17.0 Source Release Source Release (asc, sha512)

Apache Flink-shaded 16.2 Source Release Source Release (asc, sha512)

Apache Flink-connector-parent 1.1.0 Source release Source Release (asc, sha512)

验证哈希和签名 #

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

Maven 依赖 #

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

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

用户可以在 pom.xml 中包含以下依赖来在项目中使用 Apache Flink Stateful Functions。

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>statefun-sdk</artifactId>
  <version>3.3.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>statefun-flink-harness</artifactId>
  <version>3.3.0</version>
</dependency>

本地开发程序仅需要依赖 statefun-sdkstatefun-flink-harness 提供了在 IDE 中测试用户开发的程序的本地执行环境。

用户需要在 pom.xml 中添加如下依赖来使在项目中使用 Apache Flink ML。

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-ml-core</artifactId>
  <version>2.3.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-ml-iteration</artifactId>
  <version>2.3.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-ml-lib</artifactId>
  <version>2.3.0</version>
</dependency>

高级用户可以根据使用场景来只包含最小集合的依赖:

  • 依赖组件 flink-ml-core 来开发不使用迭代的自定义机器学习算法。
  • 依赖组件 flink-ml-coreflink-ml-iteration 来开发使用迭代的自定义机器学习算法。
  • 依赖组件 flink-ml-lib 来使用 Flink ML 提供的机器学习算法。

You can add the following dependencies to your pom.xml to include Apache Flink Kubernetes Operator in your project.

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-kubernetes-operator</artifactId>
  <version>1.8.0</version>
</dependency>

旧版本的更新策略 #

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

As of March 2023, the Flink community decided that upon release of a new Flink minor version, the community will perform one final bugfix release for resolved critical/blocker issues in the Flink minor version losing support. If 1.16.1 is the current release and 1.15.4 is the latest previous patch version, once 1.17.0 is released we will create a 1.15.5 to flush out any resolved critical/blocker issues.

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

所有稳定版本 #

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

  • Flink Elasticsearch Connector 3.0.0 - 2022-11-09 (Source)
  • Flink AWS Connectors 3.0.0 - 2022-11-28 (Source)
  • Flink Cassandra Connector 3.0.0 - 2022-11-30 (Source)
  • Flink AWS Connectors 4.0.0 - 2022-12-09 (Source)
  • Flink Pulsar Connector 3.0.0 - 2022-12-20 (Source)
  • Flink JDBC Connector 3.0.0 - 2022-11-30 (Source)
  • Flink RabbitMQ Connectors 3.0.0 - 2022-12-13 (Source)
  • Flink Opensearch Connector 1.0.0 - 2022-12-21 (Source)
  • Flink Google Cloud PubSub Connector 3.0.0 - 2023-01-31 (Source)
  • Flink MongoDB Connector 1.0.0 - 2023-04-03 (Source)
  • Flink AWS Connectors 4.1.0 - 2023-04-03 (Source)
  • Flink Kafka Connector 3.0.0 - 2023-04-21 (Source)
  • Flink MongoDB Connector 1.0.1 - 2023-04-24 (Source)
  • Flink JDBC Connector 3.1.0 - 2023-05-05 (Source)
  • Flink RabbitMQ Connectors 3.0.1 - 2023-05-08 (Source)
  • Flink Elasticsearch Connector 3.0.1 - 2023-05-08 (Source)
  • Flink Opensearch Connector 1.0.1 - 2023-05-08 (Source)
  • Flink Pulsar Connector 4.0.0 - 2023-05-08 (Source)
  • Flink Google Cloud PubSub Connector 3.0.1 - 2023-05-09 (Source)
  • Flink Cassandra Connector 3.1.0 - 2023-05-25 (Source)
  • Flink Pulsar Connector 3.0.1 - 2023-06-07 (Source)
  • Flink JDBC Connector 3.1.1 - 2023-06-28 (Source)
  • Flink MongoDB Connector 1.0.2 - 2023-08-15 (Source)
  • Flink HBase Connector 3.0.0 - 2023-09-1 (Source)
  • Flink Kafka Connector 3.0.1 - 2023-10-30 (Source)
  • Flink AWS Connectors 4.2.0 - 2023-11-30 (Source)
  • Flink Kafka Connector 3.0.2 - 2023-12-01 (Source)
  • Flink Pulsar Connector 4.1.0 - 2023-12-28 (Source)
  • Flink Google Cloud PubSub Connector 3.0.2 - 2024-01-12 (Source)
  • Flink Opensearch Connector 1.1.0 - 2024-02-01 (Source)
  • Flink Kafka Connector 3.1.0 - 2024-02-07 (Source)
  • Flink MongoDB Connector 1.1.0 - 2024-02-19 (Source)
  • Flink JDBC Connector 3.1.2 - 2024-02-21 (Source)
  • Apache Flink Shaded 18.0 - 2024-01-11 (Source)
  • Apache Flink Shaded 17.0 - 2023-05-08 (Source)
  • Apache Flink Shaded 16.2 - 2023-11-17 (Source)
  • Apache Flink Shaded 16.1 - 2022-11-24 (Source)
  • Apache Flink Shaded 16.0 - 2022-10-07 (Source)
  • Apache Flink Shaded 15.0 - 2022-01-21 (Source)
  • Apache Flink Shaded 14.0 - 2021-07-21 (Source)
  • Apache Flink Shaded 13.0 - 2021-04-06 (Source)
  • Apache Flink Shaded 12.0 - 2020-10-09 (Source)
  • Apache Flink Shaded 11.0 - 2020-05-29 (Source)
  • Apache Flink Shaded 10.0 - 2020-02-17 (Source)
  • Apache Flink Shaded 9.0 - 2019-11-23 (Source)
  • Apache Flink Shaded 8.0 - 2019-08-28 (Source)
  • Apache Flink Shaded 7.0 - 2019-05-30 (Source)
  • Apache Flink Shaded 6.0 - 2019-02-12 (Source)
  • Apache Flink Shaded 5.0 - 2018-10-15 (Source)
  • Apache Flink Shaded 4.0 - 2018-06-06 (Source)
  • Apache Flink Shaded 3.0 - 2018-02-28 (Source)
  • Apache Flink Shaded 2.0 - 2017-10-30 (Source)
  • Apache Flink Shaded 1.0 - 2017-07-27 (Source)
  • Apache Flink ML 2.3.0 - 2023-07-01 (Source)
  • Apache Flink ML 2.2.0 - 2023-04-19 (Source)
  • Apache Flink ML 2.1.0 - 2022-07-12 (Source)
  • Apache Flink ML 2.0.0 - 2021-01-07 (Source)