Flink 環境設定

要從 IDE 執行 flink 程式(我們可以使用 Eclipse 或 Intellij IDEA(preffered)),你需要兩個依賴項:flink-java / flink-scalaflink-clients(截至 2016 年 2 月)。可以使用 Maven 和 SBT 新增這些 JARS(如果使用 scala)。

  • Maven 的
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.1.4</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_2.11</artifactId>
    <version>1.1.4</version>
</dependency>
  • SBT 名稱:=“”

     version := "1.0"
    
     scalaVersion := "2.11.8"
    
     libraryDependencies ++= Seq(
       "org.apache.flink" %% "flink-scala" % "1.2.0",
       "org.apache.flink" %% "flink-clients" % "1.2.0"
     )
    

重要的是 :工件名稱中的 2.11scala 版本,請確保與你係統上的版本相匹配。