realized multi-d map,
kryo stopped choking.
Chris
From: "Slotterback, Chris"
Date: Sunday, August 23, 2020 at 2:17 AM
To: user
Subject: Re: Not able to force Avro serialization
And here is the deserde block where the Schema is used to generate a
GenericRecord:
@Override
public Map d
, null));
Map map = new HashMap<>();
record.getSchema().getFields().forEach(field -> map.put(field.name(),
record.get(field.name(;
return map;
}
Chris
From: "Slotterback, Chris"
Date: Sunday, August 23, 2020 at 2:07 AM
To: user
Subject: Not able to force Avro serializ
Hey guys,
I have been trying to get avro deserialization to work, but I’ve run into the
issue where flink (1.10) is trying to serialize the avro classes with kryo:
com.esotericsoftware.kryo.KryoException: java.lang.UnsupportedOperationException
Serialization trace:
reserved (org.apache.avro.Sche
