To run a flink program from your IDE(we can use either Eclipse or Intellij IDEA(preffered)), you need two dependencies:flink-java
/ flink-scala
and flink-clients
(as of february 2016). These JARS can be added using Maven and SBT(if you are using scala).
<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 name := " "
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"
)
important: the 2.11
in the artifact name is the scala version, be sure to match the one you have on your system.