How to use the TableAPI to query the data in the Sql Training Rides table ?

Posted by cristi.cioriia on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-to-use-the-TableAPI-to-query-the-data-in-the-Sql-Training-Rides-table-tp41238.html

Hey guys,

I'm pretty new to Flink, I hope I could get some help on getting data out of
a Flink cluster.

I've setup the cluster by following the steps in
https://github.com/ververica/sql-training and now I wanted to retrieve the
data from the Rides table in a Scala program, using the TableAPI. The code I
used is:



, but when I run it I get the following exception:



I have added on my classpath the following maven dependencies:



and exposed the port 6123 of the jobmanager in the docker-compose file and
checked that I can telnet to it.

Your help is greatly appreciated.

Cristi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/