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

[cristi.cioriia]

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/

[rmetzger0]

Hey,

the code and exception are not included in your message. Did you try to send them as images (screenshots)? 
I recommend sending code and exceptions as text for better searchability.

On Wed, Feb 3, 2021 at 12:58 PM cristi.cioriia <[hidden email]> wrote:

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/