Hi, After adding the following two lines the serialization trace does not show the Schema related classes:
env.getConfig().registerTypeWithKryoSerializer(GenericData.Array.class, Serializers.SpecificInstanceCollectionSerializerForArrayList.class); env.getConfig().addDefaultKryoSerializer(Schema.class,Serializers.AvroSchemaSerializer.class); However I still get exception for : Serialization trace: schema (org.apache.avro.generic.GenericData$Record) The default Kyro serializer is not able to serialize GenericData.Record class. Any other way I can get rid off this exception. P.S I do not see this exception when I run the actual pipeline, this is only coming in one of our test case -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/