Hi Timo, Thanks for your response !
I have define my Avro schema in "toKafka.avsc" and create my "toKafka.java" file with : *#java -jar avro-tools-1.8.2.jar compile schema toKafka.avsc* Then i import Avro Serialize Schema and my "toKafka.java" generated file : *import com.nybble.alpha.AvroDeserializationSchema;* *import com.nybble.alpha.toKafka;* Do i miss something ? Regards, Sebastien. 2018-04-25 11:32 GMT+02:00 Timo Walther <twal...@apache.org>: > Hi Sebastien, > > for me this seems more an Avro issue than a Flink issue. You can ignore > the shaded exception, we shade Google utilities for avoiding depencency > conflicts. > > The root cause is this: > > java.lang.NullPointerException > at org.apache.avro.specific.SpecificData.getSchema > (SpecificData.java:227) > > And the corresponding lines look like this: > > /** Find the schema for a Java type. */ > public Schema getSchema(java.lang.reflect.Type type) { > try { > return schemaCache.get(type); > } catch (Exception e) { > throw (e instanceof AvroRuntimeException) ? // line 227 > (AvroRuntimeException)e.getCause() : new > AvroRuntimeException(e); > } > } > > So I guess your schema is missing. > > I hope this helps. > > Regards, > Timo > > Am 25.04.18 um 10:57 schrieb Lehuede sebastien: > >> ava.lang.NullPointerException >> at org.apache.avro.specific.SpecificData.getSchema >> > > >