[ https://issues.apache.org/jira/browse/SPARK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15304886#comment-15304886 ]
Amit Sela commented on SPARK-15489: ----------------------------------- Got it! So I wasn't using the custom registrator correctly, it works better like this: public class ImmutablesRegistrator implements KryoRegistrator { @Override public void registerClasses(Kryo kryo) { UnmodifiableCollectionsSerializer.registerSerializers(kryo); // Guava ImmutableListSerializer.registerSerializers(kryo); ImmutableSetSerializer.registerSerializers(kryo); ImmutableMapSerializer.registerSerializers(kryo); ImmutableMultimapSerializer.registerSerializers(kryo); } } > Dataset kryo encoder fails on Collections$UnmodifiableCollection > ---------------------------------------------------------------- > > Key: SPARK-15489 > URL: https://issues.apache.org/jira/browse/SPARK-15489 > Project: Spark > Issue Type: Bug > Components: SQL > Affects Versions: 1.6.1 > Reporter: Amit Sela > > When using Encoders with kryo to encode generically typed Objects in the > following manner: > public static <T> Encoder<T> encoder() { > return Encoders.kryo((Class<T>) Object.class); > } > I get a decoding exception when trying to decode > `java.util.Collections$UnmodifiableCollection`, which probably comes from > Guava's `ImmutableList`. > This happens when running with master = local[1]. Same code had no problems > with RDD api. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org