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 版本,请确保与你系统上的版本相匹配。