spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matei Zaharia <matei.zaha...@gmail.com>
Subject Re: Kryo Serializer
Date Sun, 20 Oct 2013 06:45:19 GMT
This line here is the problem:

>    System.setProperty("spark.serializer",
> "org.apache.spark.serializer.KryoRegistrator")

It should say org.apache.spark.serializer.KryoSerializer, not Registrator.

Matei


>    System.setProperty("spark.kryo.registrator",
> classOf[EdgeWithIDRegistrator].getName)
> 
> And the exception was thrown out when I try to create the SparkContext.
> 
> Is there any suggestions?
> 
> Thank you!
> 
> Best,
> Wenlei


Mime
View raw message