Hi, Changing the classloader config to parent-first solved the issue.
Regards, Vinay Patil On Wed, Nov 7, 2018 at 7:25 AM Vinay Patil <vinay18.pa...@gmail.com> wrote: > Hi, > > Can someone please help here. > > On Nov 6, 2018 10:46 PM, "Vinay Patil [via Apache Flink User Mailing List > archive.]" <ml+s2336050n24314...@n4.nabble.com> wrote: > >> Hi, >> >> I am facing a similar issue today with Flink 1.6.0 - AvroOutputFormat >> >> AvroOutputFormat<GenericRecord> tuple2AvroOutputFormat = new >> AvroOutputFormat<>( >> new Path("<path>"), GenericRecord.class); >> >> testDataSet >> .map(new GenerateGenericRecord()) >> .returns(AvroTypeInfo.of(GenericRecord.class)) >> .output(tuple2AvroOutputFormat); >> >> Following is the exception (I have enabled forceAvro config , not sure >> why >> it still goes to Kyro Serializer) >> >> com.esotericsoftware.kryo.KryoException: Error constructing instance of >> class: org.apache.avro.Schema$LockableArrayList >> Serialization trace: >> types (org.apache.avro.Schema$UnionSchema) >> schema (org.apache.avro.Schema$Field) >> fieldMap (org.apache.avro.Schema$RecordSchema) >> schema (org.apache.avro.generic.GenericData$Record) >> at >> com.twitter.chill.Instantiators$$anon$1.newInstance(KryoBase.scala:126) >> at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1061) >> at >> com.esotericsoftware.kryo.serializers.CollectionSerializer.create(CollectionSerializer.java:89) >> >> at >> com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:93) >> >> at >> com.esotericsoftware.kryo.serializers.CollectionSerializer.read(CollectionSerializer.java:22) >> >> at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:679) >> >> Please let me know if there is a fix for this issue as I have not faced >> this >> problem for DataStreams. >> >> Regards, >> Vinay Patil >> >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> >> >> ------------------------------ >> If you reply to this email, your message will be added to the discussion >> below: >> >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/AvroInputFormat-Serialisation-Issue-tp20146p24314.html >> To start a new topic under Apache Flink User Mailing List archive., email >> ml+s2336050n1...@n4.nabble.com >> To unsubscribe from Apache Flink User Mailing List archive., click here >> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=1&code=dmluYXkxOC5wYXRpbEBnbWFpbC5jb218MXwxODExMDE2NjAx> >> . >> NAML >> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> >> >