spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrew Ash <>
Subject Re: Error related to serialisation in spark streaming
Date Wed, 04 Jun 2014 14:58:09 GMT

To confirm your code is using kryo, go to the web ui of your application
(defaults to :4040) and look at the environment tab.  If your serializer
settings are there then things should be working properly.

I'm not sure how to confirm that it works against typos in the setting, but
you can at least confirm that the setting is making it to the application
with that webui.


On Wed, Jun 4, 2014 at 3:48 AM, nilmish <> wrote:

> The error is resolved. I was using a comparator which was not serialised
> because of which it was throwing the error.
> I have now switched to kryo serializer as it is faster than java serialser.
> I have set the required config
> conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer");
> conf.set("spark.kryo.registrator", "MyRegistrator");
> and also in MyRegistrator class I have registered all the classes I am
> serialising.
> How can I confirm that my code is actually using kryo serialiser and not
> java serialiser now ?
> PS : It seems like my code is still not using kryo serialiser.
> --
> View this message in context:
> Sent from the Apache Spark User List mailing list archive at

View raw message