Connecting to Cassandra with Spark -

First of all, I bought the new O Reilly Spark book and tried those Cassandra Setup instructions I found on other StakeCurfs Flow posts and various posts and guides are also seen. None of these works - I could get as much down as I could.

This is only a handful of Dummy Test data records. I'm running the most recent Cassandra 2.0.7 Virtual Box VM provided by plasetcassandra.org linked to the main Cassandra project page.

I have downloaded the SPARC 1.2.1 source and got the latest Cassandra Connector code from Gitobb and both have built JDK 1.8.0_40 and Scala 2.11.6 setup on Mac OS 10.10.2 against Scala 2.11. .

I run Spark Shell with the Casanda Connector:

bin / spark-shell - driver-class-path ../spark-cassandra-connector/spark-cassandra -connector / target / scala-2.11 / spark-cassandra-connector-assembly-1.2.0-SNAPSHOT.jar

Then I have a simple line count type on a test table of four records The test should be:

  import com.datastax.spark.connector._ sc.stop val Conf = new org.apache.spark.SparkConf (true) .set ("spark.cssandra.connection ("Mykeyspace", "playlists") table.count  

I get the following error Ilti confusing thing is that it's going to get errors trying to find Cassandra at 127.0.0.1, but the host name also recognizes that I configured 1 9 2.168.56.101.

  15/03/16 15: 56: 54 Information cluster: New Cassandra host / 1 9 02.168.56.101:9042 Added 15/03/16 15:56:54 Information Cassandra Connector: Cassandra Connect to the cluster: Cluster on a stick 15/03/16 15:56:54 Error Server Side Tokenregister: Failure while separating from Casandra Java. Jio.io.IOException: Failed to open the connection to the cascand on 127.0.0.1:9160 & lt; Snip & gt; Java.io.IOException: Failed to fetch partition of TokenRange (0,0, set (CassandraNode (/127.0.0.1,/127.0.0.1)), from all the finishing points: CassandraNode (/127.0.0.1,/127.0.0.1 )  

BTW, I can also use a configuration file on con / spark-defaults.conf, without any spark reference closed / class-path logic I end up with the same error However, it seems easy to communicate in this post, though, and in subsequent steps.

Any thoughts?

your cassandra.yamlf Check the rpc_address config on your cassandra node in the case. It seems that the spark connector system is using that value from the table on the locale / system. It can be set to 127.0.0.1 in your cassandra.yaml.

The SPARC connector uses savings to get tokens. The division of the range from the cassandra, I am finally betting that it will be converted to C * 2.1.4, a new system called System System The table is It is gaining host metadata to find the nearest host and then query using savings on port 9160.