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
