You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by Nishant Sinha <ns...@uw.edu> on 2015/01/23 00:47:05 UTC

Exception in parsley pyspark cassandra hadoop connector

I am following the repo on github about pyspark cassandra connector at

https://github.com/Parsely/pyspark-cassandra

On executing the line :


./run_script.py src/main/python/pyspark_cassandra_hadoop_example.py run test


It ends up wit an exception:

ERROR Executor: Exception in task 9.0 in stage 2.0 (TID 14)
java.io.NotSerializableException:
scala.collection.convert.Wrappers$MapWrapper


I am unable to figure out the cause of the exception

Thanks,
Nishant