Spark Cassandra Bağlayıcısı neden NoHostAvailableException ile başarısız?

Question

Spark Cassandra Connector'ın Scala'da çalışırken sorun yaşıyorum.

• Scala 2.10.4
• kıvılcım çekirdekli 1.0.2
• cassandra-tasarruf 2.1.0 (benim yüklü cassandra v2.1.0 olan)
:

Ben bu sürümlerini kullanıyorum

• cassandra-clientutil cassandra sürücüsü çekirdekli 2.0.4 (konnektör için tavsiye?) 2.1.0
• kıvılcım cassandra-bağlayıcı 1.0.0

ben bağlanıp (kıvılcım o/w) Cassandra konuşup Spark konuşabilirsiniz ama bağlayıcı bana verir (/ Cassandra olmaksızın):

com.datastax.driver.core. exceptions.NoHostAvailableException:

(: /10.0.0.194:9042 (com.datastax.driver.core.TransportException [/10.0.0.194:9042]) bağlanamıyor çalıştı) Bütün konak (ler) sorgu için çalıştı başarısız

Neyi özlüyorum? Cassandra varsayılan bir kurulumdur (cassandra.yaml'ye göre cql için 9042 bağlantı noktası). Yerel olarak ("yerel") bağlanmaya çalışıyorum.

Benim kod: bu bağlamda

val conf = new SparkConf().setAppName("Simple Application").setMaster("local") 
val sc = new SparkContext("local","test",conf) 
val rdd = sc.cassandraTable("myks","users") 
val rr = rdd.first 
println(s"Result: $rr") 

Answer 1

Yerel Kıvılcım (yerel modda çalıştırmak için söylüyorum) ana olup Cassandra bağlantı konak belirtme.

Eğer Spark

import org.apache.spark._ 

val conf = new SparkConf(true) 
     .set("spark.cassandra.connection.host", "IP Cassandra Is Listening On") 
     .set("spark.cassandra.username", "cassandra") //Optional    
     .set("spark.cassandra.password", "cassandra") //Optional 

val sc = new SparkContext("spark://Spark Master IP:7077", "test", conf) 

https://github.com/datastax/spark-cassandra-connector/blob/master/doc/1_connecting.md

Config'i farklı bir özellik belirlemek zorunda Cassandra Bağlantı ana ayarlamak için