本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# Apache Flink
<a name="emr-flink"></a>

[Apache Flink](https://flink.apache.org/) 是一个流式处理数据流引擎，您可以使用此引擎在高吞吐量数据来源上轻松运行实时流处理。Flink 支持事件的事件时间语义、exactly-once 语义、背压控制，并针对编写流式和批处理应用程序 APIs 进行了优化。 out-of-order

此外，Flink 具有适用于第三方数据来源的连接器，例如以下内容：
+ [Amazon Kinesis Data Streams](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/kinesis/)
+ [Apache Kafka](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/kafka/)
+ [Flink Elasticsearch Connector](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/elasticsearch/)
+ [Twitter Streaming API](https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/twitter/)
+ [Cassandra](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/cassandra/)

Amazon EMR 支持 Flink 作为 YARN 应用程序，因此您可以管理集群中的资源以及其他应用程序。 Flink-on-YARN允许您提交临时的 Flink 作业，或者您可以创建一个长时间运行的集群，该集群接受多个任务并根据整体 YARN 预留量分配资源。

Flink 包含在 Amazon EMR发行版 5.1.0 及更高版本中。

**注意**  
在 Amazon EMR 5.2.1 发行版本中增加了对 `FlinkKinesisConsumer` 类的支持。

下表列出了 Amazon EMR 7.x 系列的最新发行版附带的 Flink 的版本，以及 Amazon EMR 随 Flink 一起安装的组件。

有关此版本中与 Flink 一起安装的组件的版本，请参阅 [7.13.0 版本](emr-7130-release.md)的组件版本。


**emr-7.13.0 的 Flink 版本信息**  

| Amazon EMR 发行版标签 | Flink 版本 | 随 Flink 安装的组件 | 
| --- | --- | --- | 
| emr-7.13.0 | Flink 1.20.0-amzn-7 | emrfs, hadoop-client, hadoop-mapred, hadoop-hdfs-datanode, hadoop-hdfs-library, hadoop-hdfs-namenode, hadoop-hdfs-zkfc, hadoop-httpfs-server, hadoop-kms-server, hadoop-yarn-nodemanager, hadoop-yarn-resourcemanager, hadoop-yarn-timeline-server, flink-client, flink-jobmanager-config, hudi, delta | 

下表列出了 Amazon EMR 6.x 系列的最新发行版附带的 Flink 的版本，以及 Amazon EMR 随 Flink 一起安装的组件。

有关此发行版中随 Flink 安装的组件版本，请参阅[发行版 6.15.0 组件版本](emr-6150-release.md)。


**emr-6.15.0 的 Flink 版本信息**  

| Amazon EMR 发行版标签 | Flink 版本 | 随 Flink 安装的组件 | 
| --- | --- | --- | 
| emr-6.15.0 | Flink 1.17.1-amzn-1 | emrfs, hadoop-client, hadoop-mapred, hadoop-hdfs-datanode, hadoop-hdfs-library, hadoop-hdfs-namenode, hadoop-httpfs-server, hadoop-kms-server, hadoop-yarn-nodemanager, hadoop-yarn-resourcemanager, hadoop-yarn-timeline-server, flink-client, flink-jobmanager-config, hudi, delta-standalone-connectors | 

下表列出了 Amazon EMR 5.x 系列的最新发行版附带的 Flink 的版本，以及 Amazon EMR 随 Flink 一起安装的组件。

有关此版本中随 Flink 安装的组件版本，请参阅[发行版 5.36.2 组件版本](emr-5362-release.md)。


**emr-5.36.2 的 Flink 版本信息**  

| Amazon EMR 发行版标签 | Flink 版本 | 随 Flink 安装的组件 | 
| --- | --- | --- | 
| emr-5.36.2 | Flink 1.14.2 | emrfs, hadoop-client, hadoop-mapred, hadoop-hdfs-datanode, hadoop-hdfs-library, hadoop-hdfs-namenode, hadoop-httpfs-server, hadoop-kms-server, hadoop-yarn-nodemanager, hadoop-yarn-resourcemanager, hadoop-yarn-timeline-server, flink-client, flink-jobmanager-config | 

**Topics**
+ [使用 Flink 创建集群](flink-create-cluster.md)
+ [在 Amazon EMR 中配置 Flink](flink-configure.md)
+ [在 Amazon EMR 中使用 Flink 作业](flink-jobs.md)
+ [使用 Scala Shell](flink-scala.md)
+ [查找 Flink Web 界面](flink-web-interface.md)
+ [Flink Autoscaler](flink-autoscaler.md)
+ [优化任务恢复和扩展操作的作业重启时间](flink-restart.md)
+ [在 Amazon EMR 中通过 Zeppelin 使用 Flink 作业](flink-zeppelin.md)
+ [Flink 发布历史记录](Flink-release-history.md)