Hi, I tried to reproduce the problem, but did not get the exception you posted. I implemented a job similar to yours and ran it both from the IDE and using the flink submission client using the 1.3.1 binaries. In both cases, the schema was correctly printed.
Do you get the exception in the IDE or when submitting the program to an external cluster? How do you include the flink-table.jar dependency? Do you built a fat jar or do you have it in the lib folder? Best, Fabian 2017-07-25 13:31 GMT+02:00 nragon <nuno.goncal...@wedotechnologies.com>: > Well, it might be scala conflits on my client side since no job is sent to > stream environment. > When i remove print schema or explain the job in sent and executed properly > on flink side. > > Thanks > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Flink-shaded- > table-API-tp14432p14437.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
