Re: Help with pom dependencies for Flink with Table API

2022-03-03 Thread Adesh Dsilva
Hi, Yes, you are right. I was mixing some dependencies without knowing. I did a complete reset of all dependencies and started with a fresh pom and it fixed it. Many Thanks! > On 2 Mar 2022, at 17:37, Adesh Dsilva wrote: > > Hello, > > I think I accidentally posted this question on the wron

Re: Help with pom dependencies for Flink with Table API

2022-03-03 Thread Francesco Guardiani
Hi, The moving of org.apache.flink.connector.file.table.factories.BulkReaderFormatFactory was done in master a couple of months ago by me, and it should be only on 1.15+. Could it be you're somehow mixing master snapshots with 1.14.x? Are you trying to run the job on a cluster using a Flink distri

Help with pom dependencies for Flink with Table API

2022-03-02 Thread Adesh Dsilva
Hello, I think I accidentally posted this question on the wrong email list (dev) so I am posting it again here. I am struggling to run my test Flink project with Table API I am trying to run a simple piece of code: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutio