从火花错误到Cassandra的连接

Question

我使用的是Spark2.0.2和Cassandra 3.11.2，我使用的是这段代码，但是它给了我连接错误。

./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

当我输入test.count命令时，它会给出这个错误。

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)的java.io.IOException:未能打开本机连接到卡桑德拉的{127.0.0.1}:9042

Answer 1

你能查一下yaml文件吗？似乎在任何时候都会打开足够多的并发连接。