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
