Spark Cassandra 连接

Question

当我发出这个命令时：

session.execute("CREATE KEYSPACE java_api WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 3}");

我收到此错误：

**Error while computing token map for keyspace dse_leases with datacenter GraphAnalytics: could not achieve replication factor 3 (found 2 replicas only), check your keyspace replication settings.**

在连接到 Cassandra 时我给了

public static void main(String[] args) {
    String master = "";
    String host = "";

    if (args.length != 2) {

        System.err.println("Syntax: com.datastax.spark.demo.JavaDemo <Spark Master URL> <Cassandra contact point>");
        master = "local[4]";
        host = "10.118.214.144";
    } else {
        master = args[0];
        host = args[1];
    }

    SparkConf conf = new SparkConf();
    conf.setAppName("Java API demo");
    conf.setMaster(master);
    conf.set("spark.cassandra.connection.host", host);

    SparkCassandraSave app = new SparkCassandraSave(conf);
    app.run();
}

这有什么问题吗？

Answer 1

看起来你只有两个 Cassandra 节点，但你的复制因子是三个。有几种方法。

再添加至少一个节点。
设置复制因子 2。

Spark Cassandra 连接

Spark Cassandra connection

apache-spark

cassandra-3.0