To use the Table API, add flink-table
as a maven dependency (in addition to flink-clients
and flink-core
):
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table_2.11</artifactId>
<version>1.1.4</version>
</dependency>
Ensure that the scala version (here 2.11) is compatible with your system.