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. <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> < > artifactId>maven-shade-plugin</artifactId> <version>3.2.4</version> < > executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> > </goals> <configuration> <transformers> <transformer implementation= > "org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/> </ > transformers> </configuration> </execution> </executions> </plugin> </ > plugins> </build> Best, Hang Shammon FY <zjur...@gmail.com> 于2023年3月15日周三 19:21写道： > 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. > And then you can check whether your uber jar are in the classpath of flink > cluster > > Best, > Shammon FY > > > On Wed, Mar 15, 2023 at 6:35 PM Lasse Nedergaard < > lassenedergaardfl...@gmail.com> wrote: > >> 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 in the class path. >> >> The uber jar contains Flink-connector-kafka and >> Flink-sql-connector-Kafka. >> >> I can see on my local machine it calls discovery factory in >> flink-table-common but on my cluster it use flink-table-api-java-Uber. >> >> And the list of available identities doesn’t contain ‘Kafka’ and >> upsert-Kafka as It does on my local machine. 🤔 >> >> Anyone has a clue where I should look for the problem? >> >> Med venlig hilsen / Best regards >> Lasse Nedergaard >> >>
