Re: Kafka sql with validation exception

2023-03-15 Thread Lasse Nedergaard
I got it to work Thanks for pointing me in the right direction. I had some flink dependence that wasn’t set to provided and I removed sql-connector-Kafka and that seems to fix the problem. Thanks once again Med venlig hilsen / Best regardsLasse NedergaardDen 15. mar. 2023 kl. 15.21 skrev Lasse Nede

Re: Kafka sql with validation exception

2023-03-15 Thread Lasse Nedergaard
Hi. Thanks Shammon. You are right org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory are not in the file. I’m use the shade plugin as described and the only difference from my other project are the nested project structure. I have “my project”/Flink/“my flink project”/src/ma

Re: Kafka sql with validation exception

2023-03-15 Thread Hang Ruan
Hi, Lasse, I think you should make sure the situation as Shammon said. Maybe you need to use the maven-shade-plugin like this to package, and make sure files in `META-INF/services` are merged together. org.apache.maven.plugins < > artifactId>maven-shade-plugin 3.2.4 < > executions> package

Re: Kafka sql with validation exception

2023-03-15 Thread Shammon FY
Hi Lasse I think you can first check whether there is a file `META-INF/services/org.apache.flink.table.factories.Factory` in your uber jar and there's `org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory` in the file. Flink would like to create table factory from that file.