在CAS操作上获取WriteTimoutException

Question

我试图使用phantom到Cassandra 3:9异步插入相当少量的数据，但是这个查询总是失败:插入到test_db.test_tbl（name,last,ts）值('AAA','BBB',1502109409)如果不存在，则使用TTL 0；我得到以下异常：

WriteTimeOutException：在一致性串行写入查询期间Cassandra超时（需要1个副本，但只有0个确认写入）

在com.datastax.driver.core.exceptions.writeTimeoutException.copy（writeTimeoutException.java:100)

在com.datastax.driver.core.responses$error.asexception(responses.java:134)

在com.datastax.driver.core.requestHandler$miscreativeexecution.onset(requestHandler.java:507)

在com....

insert
      .value(_.name, "aaa")
      .value(_.last, uuid)
      .value(_.ts, Random.long)
      .ifNotExists()
      .consistencyLevel_=(ConsistencyLevel.ONE)

但是异常仍然显示“在一致性串行写入查询期间Cassandra超时”

Answer 1

您正在使用If NOT exists关键字，这是一个轻量级事务

Cassandra通过扩展Paxos共识协议实现轻量级事务，该协议基于一种基于仲裁的算法。Paxos以四次往返为代价确保线性一致性。

这听起来是一个很高的成本--也许太高了，如果您有一个应用程序的罕见情况，要求每个操作都是线性的。因此，为那些绝对必要的情况保留轻量级事务。