spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 颜发才(Yan Facai) <>
Subject Re: Kryo On Spark 1.6.0
Date Sat, 14 Jan 2017 12:39:58 GMT
For scala, you could fix it by using:

By the way,
if the class is array of primitive class of Java, say byte[], then to use:

if it is array of other class, say scala.collection.mutable.WrappedArray$ofRef,
then to use:


On Tue, Jan 10, 2017 at 11:11 PM, Yang Cao <> wrote:

> If you don’t mind, could please share me with the scala solution? I tried
> to use kryo but seamed not work at all. I hope to get some practical
> example. THX
> On 2017年1月10日, at 19:10, Enrico DUrso <> wrote:
> Hi,
> I am trying to use Kryo on Spark 1.6.0.
> I am able to register my own classes and it works, but when I set
> “spark.kryo.registrationRequired “ to true, I get an error about a scala
> class:
> “Class is not registered: scala.collection.mutable.WrappedArray$ofRef”.
> Any of you has already solved this issue in Java? I found the code to
> solve it in Scala, but unable to register this class in Java.
> Cheers,
> enrico
> ------------------------------
> This message and the information contained in or attached to it are
> private and confidential and intended exclusively for the addressee. everis
> informs to whom it may receive it in error that it contains privileged
> information and its use, copy, reproduction or distribution is prohibited.
> If you are not an intended recipient of this E-mail, please notify the
> sender, delete it and do not read, act upon, print, disclose, copy, retain
> or redistribute any portion of this E-mail.

View raw message