Apache Flink 1.0.3 は最新の安定版リリースです。
Flinkを使うためにHadoopをインストールする必要はありませんが、Hadoopに格納されたデータをFlinkで使うつもりであれば、インストールされたHadoopのバージョンと一致するバージョンを取り上げてください。 こうしたくない場合は、Hadoop バージョン 1を取り上げてください。
| Scala 2.10 | Scala 2.11 | |
|---|---|---|
| Hadoop 1.2.1 | ダウンロード | |
| Hadoop 2.3.0 | ダウンロード | ダウンロード |
| Hadoop 2.4.1 | ダウンロード | ダウンロード |
| Hadoop 2.6.0 | ダウンロード | ダウンロード |
| Hadoop 2.7.0 | ダウンロード | ダウンロード |
ソースコードをレビューするか、このパッケージを使って独自のFlinkをビルドしてください
プロジェクトにApache Flinkを含めるためにpom.xmlに以下の依存を追加することができます。
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.0.3</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.10</artifactId>
<version>1.0.3</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.10</artifactId>
<version>1.0.3</version>
</dependency>これらの依存はローカルの実行環境を含むため、ローカルのテストをサポートします。
1.0.3-hadoop1 を使います。flink-java artifact id を flink-scala_2.10 と flink-streaming-scala_2.10を使うflink-streaming-java_2.10に置き換えます。. Scala 2.11 の依存のために、_2.10の代わりにサフィックス_2.11 を使います。