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 > >
