我使用Spark 2.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命令时，它会给我这个错误 .
java.io.IOException：无法在{127.0.0.1}打开与Cassandra的本机连接：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 回答
你能查看yaml文件吗？似乎在任何时刻都可以打开足够多的并发连接 .