尽管QUORUM一致性级别与复制因子3不一致，但Cassandra不一致

Question

我对卡珊德拉的一致性有疑问。我在集群中有3个Cassandra节点(版本2.0.14.352 ),我使用< b >一致性级别仲裁读取和写入，我的< b >复制因子是3。如果我理解replication_factor " >这个对我来说卡珊德拉应该是一致的，因为2 ^ 2

final Instant t1 = Instant.parse("2000-01-01T00:00:00.000Z");
final Instant t2 = Instant.parse("2000-02-01T00:00:00.000Z");

for (int i = 0; i < 100; i++) {
    dataProvider.setValue(t1, new Double(1));
    //If the next line is removed, the test will pass
    dataProvider.setValue(t2, new Double(3));

    dataProvider.saveToDB();
    dataProvider.clear();
    assertEquals("i=" + i, new Double(3), dataProvider.getValue(t2));
    assertEquals("i=" + i, new Double(1), dataProvider.getValue(t1));

    dataProvider.setValue(t1, new Double(2));
    dataProvider.saveToDB();
    dataProvider.clear();
    assertEquals("i=" + i, new Double(2), dataProvider.getValue(t1));

    dataProvider.setValue(t1, new Double(101));
    dataProvider.saveToDB();
    dataProvider.clear();
    assertEquals("i=" + i, new Double(101), dataProvider.getValue(t1));
}

与相应的表

CREATE TABLE keyspace.table(
  id text,
  year int,
  month int,
  time timestamp,
  value double,
  PRIMARY KEY ((id, year, month), time)
)

dataProvider.setValue（）内部将给定值放入NavigableMap。dataProvider.saveToDB（）将数据插入Cassandra。在这里，我一方面尝试异步插入数据，并等待所有ResultSetFuture完成，另一方面同步执行语句。但这只影响性能。详细来说，保存方法看起来像

final List<ResultSetFuture> sets = newLinkedList();
Batch batch = QueryBuilder.batch();
int batchsize=0;
for (Map.Entry<Instant, Double> entry : valueMap) {
    final Instant instant = entry.getKey();
    final ZonedDateTime zonedDateTime = instant.atZone(ZoneId.of("UTC"));
    final Date date = Date.from(instant);
    final Insert insert = QueryBuilder.insertInto(table)
            .value(ID, id)
            .value(YEAR, zonedDateTime.getYear())
            .value(MONTH, zonedDateTime.getMonthValue())
            .value(TIME, date)
            .value(VALUE, entry.getValue());
    batch.add(insert);
    ++batchsize;
    if(batchsize % 200 == 0){
        sets.add(cassandraConnector.executeAsync(batch));
        batch = QueryBuilder.batch();
    }
}
if(batchsize % 200 != 0) { //es gibt noch nicht abgeschickte Statements
    sets.add(cassandraConnector.executeAsync(batch));
}
cassandraConnector.waitForFinish(sets);

CassandraConnector管理连接。我正在等待所有ResultSets完成

public boolean waitForFinish(List<ResultSetFuture> sets) {
    ResultSet result = null;
    for (final ResultSetFuture resultSetFuture : sets) {
        // Wait until finished
        try {
            result = resultSetFuture.get();
        } catch (InterruptedException e) {
            resultSetFuture.cancel(true);
            e.printStackTrace();
            return false;
        } catch (ExecutionException e) {
            e.printStackTrace();
            if (result != null) {
                ExecutionInfo executionInfo = result.getExecutionInfo();
                System.out.println("Timout from server with IP: " + executionInfo.getTriedHosts());
            }
            return false;
        }
    }
    return true;
}

奇怪的是，如果我删除注释下面的行，测试就会通过，不管我执行它的频率是多少。但是如果我运行测试而不删除该行，有时它会在第一个循环中失败，但有时它会运行3个循环直到失败。此外，它总是在不同的行失败。例如

java.lang.AssertionError: i=0 
Expected :101
Actual   :2

我也得到了

java.lang.AssertionError: i=2
Expected :2
Actual   :101

所以看起来卡桑德拉写了1，之后卡桑德拉没有写2，而是恢复了我在1之前写的101。有人对这种行为有解释吗？如果我移除线，为什么测试会通过？我正在写不同的分区。我尝试将一致性级别更改为ALL，但是行为没有改变。

Answer 1

我解决了。显然，时钟不是100%同步的。在创建insert语句时，我添加了.using（timestamp（System.nanoTime（）/1000））；现在测试通过了。