Table APIs with Flink 1.2.0

[DataFlair Team]

Table API classes are not getting resolved when the dependencies added in ‘pom.xml’ are for flink version 1.2.0. As an example I am getting the error “The import org.apache.flink.api.table cannot be resolved” for the import statement. Hence the code cannot be compiled. But they work fine and there are no errors when the Flink version is 1.1.3.

[DataFlair Team]

You need to use below maven dependencies for Flink 1.2.0 version:

<dependencies>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-table_2.11</artifactId>
  <version>1.2.0</version>
</dependency>

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-scala_2.11</artifactId>
  <version>1.2.0</version>
</dependency>

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.2.0</version>
</dependency>
</dependencies>

[Author]

Posts