Connection to Cassandra from spark Error

0
votes

I am using Spark 2.0.2 and Cassandra 3.11.2 I am using this code but it give me connection error.

./spark-shell --jars ~/spark/spark-cassandra-connector/spark-cassandra-connector/target/full/scala-2.10/spark-cassandra-connector-assembly-2.0.5-121-g1a7fa1f8.jar
import com.datastax.spark.connector._

 val conf = new SparkConf(true).set("spark.cassandra.connection.host", "localhost")
val test = sc.cassandraTable("sensorkeyspace", "sensortable")
test.count

When I enter test.count command it give me this error.

java.io.IOException: Failed to open native connection to Cassandra at {127.0.0.1}:9042 at com.datastax.spark.connector.cql.CassandraConnector$.com$datastax$spark$connector$cql$CassandraConnector$$createSession(CassandraConnector.scala:168) at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$8.apply(CassandraConnector.scala:154)

1
scalaapache-sparkcassandra

1 Answers

0
votes

Can you check the yaml file? It seems the number of enough concurrent connections are open at any instance of time.