Hi Adesh, have you tried building your project with a clean classpath, i.e. mvn clean ...? Additionally, you could also try deleting org/apache/flink from your local .m2 repository to have an even cleaner repo. It looks like a BulkReaderFormatFactory from the current master branch [1] has been referenced while Flink 1.14.3 [2] is used.
[1] https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/factories/BulkReaderFormatFactory.java [2] https://github.com/apache/flink/blob/release-1.14.3/flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/BulkReaderFormatFactory.java Best regards, Jing On Wed, Mar 2, 2022 at 6:34 PM Adesh Dsilva <adeshavin...@gmail.com> wrote: > Hi > > 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.getExecutionEnvironment(); > env.setRuntimeMode(RuntimeExecutionMode.BATCH); > > StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); > > Path in = Path.fromLocalFile(new File("part-v001-o000-r-00330.avro")); > AvroInputFormat<BidSample> users = new AvroInputFormat<>(in, > BidSample.class); > DataStream<BidSample> bidsDS = env.createInput(users); > > Table bidsTable = tableEnv.fromDataStream(bidsDS); > bidsTable.printSchema(); > > > And here is my pom dependencies > > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-streaming-java_2.12</artifactId> > <version>1.14.3</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-clients_2.12</artifactId> > <version>1.14.3</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table-api-java-bridge_2.12</artifactId> > <version>1.14.3</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table-planner_2.12</artifactId> > <version>1.14.3</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table-common</artifactId> > <version>1.14.3</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table-api-java</artifactId> > <version>1.14.3</version> > </dependency> > > > > But I keep getting below error: > Caused by: java.lang.ClassNotFoundException: > org.apache.flink.connector.file.table.factories.BulkReaderFormatFactory > at > java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:766) > at > java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) > > > > Any help to know why this is happening and fix it would be much > appreciated. > > Many thanks, > Adesh DSilva
