While getting up and running with Spark & Cassandra I am coming up against
the following problem
I've narrowed it down to the following 2 lines ( originally was a large
query )
val pcollection2 = sc.parallelize(Seq(("11111111", "Filter1", "A", "X")))
pcollection2.saveToCassandra("signals", "segmentations",
Seq("lognet_customer_no", "query_id", "message_id", "location_id"))
When this runs I always get the following error on each Spark node
java.lang.ClassCastException:
com.datastax.driver.core.DefaultResultSetFuture cannot be cast to
com.google.common.util.concurrent.ListenableFuture
Any help or points, gratefully received
K
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/ClassCastException-when-calling-saveToCassandra-tp12563.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
