flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefan Richter <s.rich...@data-artisans.com>
Subject Re: Guava immutable collection kryo serialization
Date Thu, 21 Jul 2016 08:36:34 GMT
Hi,

to answer this question, it would be helpful if you could provide the stacktrace of your exception
and the code you use to register the serializer.

Best,
Stefan

> Am 21.07.2016 um 05:28 schrieb Shaosu Liu <shu@uber.com>:
> 
> 
> Hi,
> 
> How do I do Guava Immutable collections serialization in Flink?
> 
> I am getting error 
> 
> Caused by: java.io.NotSerializableException: de.javakaffee.kryoserializers.guava.ImmutableMapSerializer
> 
> when I register ImmutableMap to be serialized by the ImmutableMapSerializer. I am using
the latest version of 0.38.
> 
> -- 
> Cheers,
> Shaosu


Mime
View raw message