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/
