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/
