卡珊德拉。没有足够的副本可用 - Java 驱动程序行为与 CQL 控制台不同

Question

我有一个非常简单的集群，有2个节点。我创建了一个具有简单策略复制和复制因子为2的密钥空间。对于读取和写入，我总是使用默认数据一致性级别 ONE。

如果我使用datastax java驱动程序取下两个节点中的一个，我仍然可以读取数据，但当我尝试写入时，我得到“没有足够的副本可用于一致性为1的查询（需要1个副本，但只有0个副本）”。

奇怪的是，如果我使用CQL控制台执行完全相同的insert语句，它就不会有任何问题。即使在使用CQL控制台时，数据一致性级别也为1。

我错过了什么吗？

短暂性缺血性发作

更新

我做了更多的测试，只有当我使用Batch语句时才会出现问题。如果我直接执行准备好的语句，它就可以工作。有什么想法吗？

这里是代码

    Cluster cluster = Cluster.builder()
            .addContactPoint("192.168.1.10")
            .addContactPoint("192.168.1.12")
            .build();

    Session session = cluster.connect();
    session.execute("use giotest");

    BatchStatement batch = new BatchStatement();
    PreparedStatement statement = session.prepare("INSERT INTO hourly(series_id, timestamp, value) VALUES (?, ?, ?)");

    for (int i = 0; i < 50; i++) {
        batch.add(statement.bind(new Long(i), new Date(), 2345.5));
    }

    session.execute(batch);
    batch.clear();
    session.close();
    cluster.close();  

Answer 1

如果还没有，请确保在驱动程序级别指定了两台主机。

Answer 2

默认情况下，批处理是原子的：如果协调器在批处理中途失败，Cassandra 将确保其他节点重放剩余的请求。它为此使用分布式批处理日志（有关更多详细信息，请参阅此帖子）。

此批处理日志必须复制到协调器以外的至少一个副本，否则会破坏上述机制。

在您的情况下，没有其他副本，只有协调器。所以卡桑德拉告诉你，它不能提供原子批次的保证。另见关于卡桑德拉-7870的讨论。