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
Hello everyone,
Is there a python connector for Spark and Cassandra as there is one for
Java. I found a Java connector by DataStax on github:
https://github.com/datastax/spark-cassandra-connector
I am looking for something similar in Java.
Thanks