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
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
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
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.
Hi.
I have a simple job creating a table from Kafka. It works perfect on my local
machine but when I build a Uber jar and use the official Flink image I get a
validation exception.
Could not find any factory for identifier ‘Kafka’ that implements
org.Apache.Flink.table.dynamicTableFactory
