Also please make sure you are specifying the fully qualified name of
registrator class in the sparkconf configuration correctly.
On Dec 11, 2014 5:57 PM, "bonnahu" wrote:
> class MyRegistrator implements KryoRegistrator {
>
> public void registerClasses(Kryo kryo) {
> kryo
class MyRegistrator implements KryoRegistrator {
public void registerClasses(Kryo kryo) {
kryo.register(ImpressionFactsValue.class);
}
}
change this class to public and give a try
--
View this message in context:
http://apache-spark-user-list.1001560.n
