

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

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

[Apache Flink](https://flink.apache.org/) 是一種串流資料流程引擎，可用來在高輸送量的資料來源上執行即時串流處理。Flink 可支援亂序排列事件的事件時間語意、僅此一次的語意和背壓控制，還有針對同時撰寫串流和批次應用程式進行優化的 API。

此外 Flink 也提供適用於第三方資料來源的連接器，例如以下各項：
+ [Amazon Kinesis Data Streams](https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/kinesis.html)
+ [Apache Kafka](https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/kafka.html)
+ [Flink Elasticsearch 連接器](https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html)
+ [Twitter 串流 API](https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/twitter.html)
+ [Cassandra](https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/cassandra.html)

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.12.0 元件版本。](emr-7120-release.md)


**emr-7.12.0 的 Flink 版本資訊**  

| Amazon EMR 發行標籤 | Flink 版本 | 與 Flink 一起搭配安裝的元件 | 
| --- | --- | --- | 
| emr-7.12.0 | Flink 1.20.0-amzn-6 | 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 自動擴展器](flink-autoscaler.md)
+ [優化任務復原和擴展操作的作業重新啟動時間](flink-restart.md)
+ [在 Amazon EMR 中使用 Zeppelin 的 Flink 作業](flink-zeppelin.md)
+ [Flink 版本歷史記錄](Flink-release-history.md)