Re: Cannot load user class: avro GenericRecord

2022-01-11 Thread Jason Politis
I realize those 2 specific ones are commented out, but I believe they are only used in flink-sql, and there's currently an issue when I include them in the pom. I might not have the repos correct. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io

Re: Cannot load user class: avro GenericRecord

2022-01-11 Thread Jason Politis
http://maven.apache.org/POM/4.0.0"; xmlns:xsi=" http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> 4.0.0 boars_head w_build_d 0.1 jar Cql Flink DataStream Java https://flink.apache.org UTF-8 1.14.0 1.8

Re: Cannot load user class: avro GenericRecord

2022-01-10 Thread Caizhi Weng
Hi! Could you share your pom.xml file of your user project? Did you include the flink-avro dependency? Also did you add the avro format jar to the lib directory of your Flink distribution? Jason Politis 于2022年1月11日周二 08:42写道: > Good evening all, > > I'm working on a project for a client. We ar