【发布时间】：2017-01-10 06:50:37
【问题描述】：
我正在尝试设置 cassandra，但遇到了一些问题，谷歌和其他问题在这里没有帮助。
从 cqlsh 中，当我在创建表后尝试查询表时得到 NoHostAvailable:：
Connected to DS Cluster at 10.101.49.129:9042.
[cqlsh 5.0.1 | Cassandra 3.0.9 | CQL spec 3.4.0 | Native protocol v4]
Use HELP for help.
cqlsh> use test;
cqlsh:test> describe kv;
CREATE TABLE test.kv (
key text PRIMARY KEY,
value int
) WITH bloom_filter_fp_chance = 0.01
AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'}
AND comment = ''
AND compaction = {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
AND compression = {'chunk_length_in_kb': '64', 'class': 'org.apache.cassandra.io.compress.LZ4Compressor'}
AND crc_check_chance = 1.0
AND dclocal_read_repair_chance = 0.1
AND default_time_to_live = 0
AND gc_grace_seconds = 864000
AND max_index_interval = 2048
AND memtable_flush_period_in_ms = 0
AND min_index_interval = 128
AND read_repair_chance = 0.0
AND speculative_retry = '99PERCENTILE';
cqlsh:test> select * from kv;
NoHostAvailable:
所有节点都按照nodetool 启动并运行。
当我尝试从 Spark 连接时，我得到了类似的结果——一切正常，我可以操作并连接到表，直到我尝试访问任何数据，然后它失败了。
val df = sql.read.format("org.apache.spark.sql.cassandra").options(Map("keyspace" -> "test2", "table" -> "words")).load
df: org.apache.spark.sql.DataFrame = [word: string, count: int]
df.show
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1.0 failed 4 times, most recent failure: Lost task 0.3 in stage 1.0 (TID 25, HOSTNAME): java.io.IOException: Failed to open native connection to Cassandra at {10.101.49.129, 10.101.50.24, 10.101.61.251, 10.101.49.141, 10.101.60.94, 10.101.63.27, 10.101.49.5}:9042
at com.datastax.spark.connector.cql.CassandraConnector$.com$datastax$spark$connector$cql$CassandraConnector$$createSession(CassandraConnector.scala:162)
at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$3.apply(CassandraConnector.scala:148)
at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$3.apply(CassandraConnector.scala:148)
at com.datastax.spark.connector.cql.RefCountedCache.createNewValueAndKeys(RefCountedCache.scala:31)
at com.datastax.spark.connector.cql.RefCountedCache.acquire(RefCountedCache.scala:56)
at com.datastax.spark.connector.cql.CassandraConnector.openSession(CassandraConnector.scala:81)
at com.datastax.spark.connector.rdd.CassandraTableScanRDD.compute(CassandraTableScanRDD.scala:325)
at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:306)
...
Caused by: java.lang.NoSuchMethodError: com.google.common.util.concurrent.Futures.withFallback(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureFallback;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture;
at com.datastax.driver.core.Connection.initAsync(Connection.java:177)
at com.datastax.driver.core.Connection$Factory.open(Connection.java:731)
at com.datastax.driver.core.ControlConnection.tryConnect(ControlConnection.java:251)
如果这是一个幼稚的问题，我深表歉意，并提前感谢您。
【问题讨论】：
-
对于 cqlsh，您可能遇到了 RF 错误。我的猜测是密钥空间不会在您所在的节点上复制。对于第二个错误，它看起来像是 guava 的依赖错误，通常这意味着您使用了错误的 Spark Cassandra 连接器包。
-
感谢 Russ，RF 修复成功了。我原以为 cassandra 会让每个节点上的每个键空间都可用，但是像 hadoop 一样分发数据？有什么需要调整的吗？
-
默认策略“SimpleStrategy”将数据放在所有节点上，但不建议在生产环境中使用。 “NetworkTopologyStrategy”指定应在哪些数据中心复制数据。但是，数据中心名称与集群中的数据中心匹配很重要。
-
@RussS 如果你把这个作为答案，我会接受它是正确的......但如果你能向我解释更多关于这个神秘的复制策略的事情，我也会非常感激......我只是希望数据在复制不完善的节点（如 hadoop）之间拆分，但也能够从任何节点访问任何内容。我只有一个数据中心、一个集群、一个机架。