flink源碼編譯

1.下載下傳flink源碼

git clone https://github.com/apache/flink.git

需要源碼來建構Flink。可以[下載下傳發行版源碼]({{ site.download_url }}) 或這 [從 git 倉庫複制]({{ site.github_url }})。

此外，您需要 Maven 3 和 JDK (Java Development Kit)。

需要使用Java 8及以上JDK版本來建構Flink 。

注意：Maven 3.3.x 可以建構 Flink，但不能屏蔽某些依賴。Maven 3.2.5 可以正常建立庫。請使用 Java 8u51 或更高版本來建構單元測試，以避免用PowerMock運作單元測試失敗。

是以我這邊是使用的Maven 3.2.5

2.建構

建構 Flink 最簡單的方法是運作：

• mvn clean install -DskipTests
             

這個 Maven (

mvn

) 指令是首先删除所有已生成的檔案 (

clean

) ，然後建立一個新的 Flink 二進制檔案 (

install

)。

要加快建構速度你可以跳過測試、QA 插件 和 JavaDocs：

mvn clean install -DskipTests -Dfast
           

預設建構為 Hadoop 2 添加了 Flink 特定的 JAR，以允許 Flink 與 HDFS 和 YARN 一起使用。

haddoop 版本支援

{% info %} 大多數的使用者不需要手動執行此操作。 [下載下傳頁面]({{ site.download_url }}) 包含了對應常見 Hadoop 版本的二進制包。

Flink 所依賴的 HDFS 和 YARN 都來自于 Apache Hadoop。目前存在許多不同的 Hadoop 版本（包括上遊項目和不同的 Hadoop 發行版）。如果使用錯誤的版本組合，可能會産生異常。

Flink支援2.4.0及以上的hadoop 版本。 你也可以指定建構特定的 Hadoop 版本：

mvn clean install -DskipTests -Dhadoop.version=2.6.1