You need to set the following jar (cassandra-connector
http://central.maven.org/maven2/com/datastax/spark/spark-cassandra-connector_2.10/1.1.0-alpha3/spark-cassandra-connector_2.10-1.1.0-alpha3.jar)
in the classpath like:
Hi all,
I'm having trouble troubleshooting this particular block of code for Spark
Streaming and saving to Cassandra:
val lines = ssc.socketTextStream(args(0), args(1).toInt,
StorageLevel.MEMORY_AND_DISK_SER)
val words = lines.flatMap(_.split( ))
val wordCounts = words.map(x = (x,
Looks like you're having some classpath issues.
Are you providing your spark-cassandra-driver classes to your job?
sparkConf.setJars(Seq(jars...)) ?
On Tue, Oct 28, 2014 at 5:34 PM, Harold Nguyen har...@nexgate.com wrote:
Hi all,
I'm having trouble troubleshooting this particular block of
