Front Page Forums Apache Flink Table APIs with Flink 1.2.0

This topic contains 1 reply, has 1 voice, and was last updated by  DataFlair Team 2 months, 1 week ago.

Viewing 2 posts - 1 through 2 (of 2 total)
  • Author
    Posts
  • #6581

    DataFlair Team
    Participant

    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.

    #6582

    DataFlair Team
    Participant

    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>
Viewing 2 posts - 1 through 2 (of 2 total)

You must be logged in to reply to this topic.